Skip to content

Commit bd172ba

Browse files
Merge pull request #121 from aethernetio/120-many-got-0-bytes-transfered-on-windows
120 many got 0 bytes transfered on windows
2 parents e8f0f9e + 935ac6f commit bd172ba

2 files changed

Lines changed: 1 addition & 3 deletions

File tree

aether/stream_api/unidirectional_gate.h

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -45,8 +45,6 @@ class ParallelGate final : public ByteIGate {
4545
: write_gate_{std::move(write_gate)},
4646
read_gate_{std::move(read_gate)},
4747
write_gate_update_{write_gate_.gate_update_event().Subscribe(
48-
gate_update_event_, MethodPtr<&GateUpdateEvent::Emit>{})},
49-
read_gate_update_{read_gate_.gate_update_event().Subscribe(
5048
gate_update_event_, MethodPtr<&GateUpdateEvent::Emit>{})} {}
5149

5250
ActionView<StreamWriteAction> Write(DataBuffer&& data,
@@ -72,7 +70,6 @@ class ParallelGate final : public ByteIGate {
7270
TReadGate read_gate_;
7371
GateUpdateEvent gate_update_event_;
7472
Subscription write_gate_update_;
75-
Subscription read_gate_update_;
7673
};
7774
} // namespace ae
7875

aether/transport/low_level/tcp/win_tcp.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -389,6 +389,7 @@ WinTcpTransport::WinTcpTransport(ActionContext action_context,
389389
: action_context_{action_context},
390390
poller_{std::move(poller)},
391391
endpoint_{endpoint},
392+
socket_{INVALID_SOCKET},
392393
socket_packet_queue_manager_{action_context_},
393394
read_overlapped_{{}, EventType::kRead},
394395
write_overlapped_{{}, EventType::kWrite} {

0 commit comments

Comments
 (0)