Skip to content

Commit 9dcb2e7

Browse files
tbartelmesstanner0101
authored andcommitted
Update for latest NIO API's (#13)
1 parent a24ec97 commit 9dcb2e7

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

Sources/NIOPostgres/Connection/PostgresConnection+Connect.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ extension PostgresConnection {
88
return bootstrap.connect(to: socketAddress).flatMap { channel in
99
return channel.pipeline.addHandlers([
1010
ByteToMessageHandler(PostgresMessageDecoder()),
11-
PostgresMessageEncoder(),
11+
MessageToByteHandler(PostgresMessageEncoder()),
1212
PostgresConnectionHandler(),
1313
]).map {
1414
return .init(channel: channel)

Sources/NIOPostgres/Message/PostgresMessageEncoder.swift

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ public final class PostgresMessageEncoder: MessageToByteEncoder {
55
public typealias OutboundIn = PostgresMessage
66

77
/// See `MessageToByteEncoder`.
8-
public func encode(context: ChannelHandlerContext, data message: PostgresMessage, out: inout ByteBuffer) throws {
8+
public func encode(data message: PostgresMessage, out: inout ByteBuffer) throws {
99
// print("PostgresMessage.ChannelEncoder.encode(\(data))")
1010

1111
// serialize identifier

0 commit comments

Comments
 (0)