Home
last modified time | relevance | path

Searched refs:StreamSink (Results 1 – 6 of 6) sorted by relevance

/external/webrtc/rtc_base/
Dtest_utils.cc16 StreamSink::StreamSink() = default;
17 StreamSink::~StreamSink() = default;
Dtest_utils.h42 class StreamSink : public sigslot::has_slots<> {
44 StreamSink();
45 ~StreamSink() override;
48 stream->SignalEvent.connect(this, &StreamSink::OnEvent); in Monitor()
66 socket->SignalConnectEvent.connect(this, &StreamSink::OnConnectEvent); in Monitor()
67 socket->SignalReadEvent.connect(this, &StreamSink::OnReadEvent); in Monitor()
68 socket->SignalWriteEvent.connect(this, &StreamSink::OnWriteEvent); in Monitor()
69 socket->SignalCloseEvent.connect(this, &StreamSink::OnCloseEvent); in Monitor()
Dsocket_unittest.cc46 using webrtc::testing::StreamSink;
232 StreamSink sink; in ConnectInternal()
287 StreamSink sink; in ConnectWithDnsLookupInternal()
335 StreamSink sink; in ConnectFailInternal()
368 StreamSink sink; in ConnectWithDnsLookupFailInternal()
428 StreamSink sink; in ConnectWhileNotClosedInternal()
469 StreamSink sink; in ServerCloseDuringConnectInternal()
497 StreamSink sink; in ClientCloseDuringConnectInternal()
535 StreamSink sink; in ServerCloseInternal()
608 StreamSink sink; in CloseInClosedCallbackInternal()
[all …]
Dvirtual_socket_unittest.cc53 using webrtc::testing::StreamSink;
274 StreamSink sink; in ConnectTest()
342 StreamSink sink; in ConnectToNonListenerTest()
377 StreamSink sink; in CloseDuringConnectTest()
464 StreamSink sink; in CloseTest()
514 StreamSink sink; in TcpSendTest()
786 StreamSink sink; in CrossFamilyConnectionTest()
1069 StreamSink sink; in TEST_F()
Dphysical_socket_server_unittest.cc197 webrtc::testing::StreamSink sink; in ConnectInternalAcceptError()
/external/rust/crates/futures/tests/
Dfuture_try_flatten_stream.rs55 struct StreamSink<T, E, Item>(PhantomData<(T, E, Item)>); in assert_impls() struct
57 impl<T, E, Item> Stream for StreamSink<T, E, Item> { in assert_impls() implementation
64 impl<T, E, Item> Sink<Item> for StreamSink<T, E, Item> { in assert_impls() implementation
84 let s = ok(StreamSink::<(), (), ()>(PhantomData)).try_flatten_stream(); in assert_impls()
88 let s = ok(StreamSink::<(), (), ()>(PhantomData)).flatten_sink(); in assert_impls()