@@ -59,8 +59,6 @@ actor Speaker<SendMsg: RPCMessage & Message, RecvMsg: RPCMessage & Message> {
5959private let sender : Sender < SendMsg >
6060private let receiver : Receiver < RecvMsg >
6161private let secretary = RPCSecretary < RecvMsg > ( )
62- private var messageBuffer : MessageBuffer = . init( )
63- private var readLoopTask : Task < Void , any Error > ?
6462let role : ProtoRole
6563
6664 /// Creates an instance that communicates over the provided file handles.
@@ -136,30 +134,6 @@ actor Speaker<SendMsg: RPCMessage & Message, RecvMsg: RPCMessage & Message> {
136134case message( RecvMsg )
137135case RPC( RPCRequest < SendMsg , RecvMsg > )
138136}
139-
140- private actor MessageBuffer {
141- private var messages : [ IncomingMessage ] = [ ]
142- private var continuations : [ CheckedContinuation < IncomingMessage ? , Never > ] = [ ]
143-
144- func push( _ message: IncomingMessage ? ) {
145- if let continuation= continuations. first{
146- continuations. removeFirst ( )
147- continuation. resume ( returning: message)
148- } else if let message= message{
149- messages. append ( message)
150- }
151- }
152-
153- func next( ) async -> IncomingMessage ? {
154- if let message= messages. first{
155- messages. removeFirst ( )
156- return message
157- }
158- return await withCheckedContinuation { continuationin
159- continuations. append ( continuation)
160- }
161- }
162- }
163137}
164138
165139extension Speaker : AsyncSequence , AsyncIteratorProtocol {