Searched refs:ConnectionEvent (Results 1 – 4 of 4) sorted by relevance
8 rpc CreateConnection(ConnectionMsg) returns (stream ConnectionEvent) {}17 rpc FetchIncomingConnection(google.protobuf.Empty) returns (stream ConnectionEvent) {}46 message ConnectionEvent { message
64 ::grpc::ServerWriter<ConnectionEvent>* writer) override { in CreateConnection()71 …nnection_events_.emplace_back(std::make_unique<::bluetooth::grpc::GrpcEventQueue<ConnectionEvent>>( in CreateConnection()266 ::grpc::ServerWriter<ConnectionEvent>* writer) override { in FetchIncomingConnection()270 …nnection_events_.emplace_back(std::make_unique<::bluetooth::grpc::GrpcEventQueue<ConnectionEvent>>( in FetchIncomingConnection()357 ConnectionEvent success; in OnConnectSuccess()366 ConnectionEvent fail; in OnConnectFail()385 std::shared_ptr<::bluetooth::grpc::GrpcEventQueue<ConnectionEvent>> event_stream) in Connection()520 ConnectionEvent disconnection; in OnDisconnection()546 std::shared_ptr<::bluetooth::grpc::GrpcEventQueue<ConnectionEvent>> event_stream_;556 …std::vector<std::shared_ptr<::bluetooth::grpc::GrpcEventQueue<ConnectionEvent>>> per_connection_ev…
26 _sink: ServerStreamingSink<ConnectionEvent>, in create_connection() argument87 _sink: ServerStreamingSink<ConnectionEvent>, in fetch_incoming_connection() argument
62 evt_rx: Receiver<ConnectionEvent>,67 pub enum ConnectionEvent { enum267 evt_tx: Sender<ConnectionEvent>, in run_connection() argument279 evt_tx.send(ConnectionEvent::Disconnected(evt.get_reason())).await.unwrap(); in run_connection()282 … AuthenticationComplete(_) => evt_tx.send(ConnectionEvent::AuthenticationComplete).await.unwrap(), in run_connection()