diff --git a/aether/stream_api/unidirectional_gate.h b/aether/stream_api/unidirectional_gate.h index dc6abd57..02c7f4cf 100644 --- a/aether/stream_api/unidirectional_gate.h +++ b/aether/stream_api/unidirectional_gate.h @@ -45,8 +45,6 @@ class ParallelGate final : public ByteIGate { : write_gate_{std::move(write_gate)}, read_gate_{std::move(read_gate)}, write_gate_update_{write_gate_.gate_update_event().Subscribe( - gate_update_event_, MethodPtr<&GateUpdateEvent::Emit>{})}, - read_gate_update_{read_gate_.gate_update_event().Subscribe( gate_update_event_, MethodPtr<&GateUpdateEvent::Emit>{})} {} ActionView Write(DataBuffer&& data, @@ -72,7 +70,6 @@ class ParallelGate final : public ByteIGate { TReadGate read_gate_; GateUpdateEvent gate_update_event_; Subscription write_gate_update_; - Subscription read_gate_update_; }; } // namespace ae diff --git a/aether/transport/low_level/tcp/win_tcp.cpp b/aether/transport/low_level/tcp/win_tcp.cpp index 6fa3c032..881b3a03 100644 --- a/aether/transport/low_level/tcp/win_tcp.cpp +++ b/aether/transport/low_level/tcp/win_tcp.cpp @@ -389,6 +389,7 @@ WinTcpTransport::WinTcpTransport(ActionContext action_context, : action_context_{action_context}, poller_{std::move(poller)}, endpoint_{endpoint}, + socket_{INVALID_SOCKET}, socket_packet_queue_manager_{action_context_}, read_overlapped_{{}, EventType::kRead}, write_overlapped_{{}, EventType::kWrite} {