Searched refs:emits (Results 1 – 22 of 22) sorted by relevance
134 assertThat(cert_channel).emits(L2capMatchers.Data(b'abc'))159 assertThat(cert_channel).emits(L2capMatchers.IFrame(tx_seq=0, payload=b'abc' * 34))182 assertThat(cert_channel).emits(L2capMatchers.Data(b'hello'))204 assertThat(cert_channel).emits(L2capMatchers.Data(b'a' * 48))242 … assertThat(self.cert_l2cap.get_control_channel()).emits(L2capMatchers.ConfigurationResponse())274 …assertThat(self.cert_l2cap.get_control_channel()).emits(L2capMatchers.ConfigurationResponse(), at_…290 …assertThat(self.cert_l2cap.get_control_channel()).emits(L2capMatchers.ConfigurationRequest(), at_l…329 assertThat(cert_channel).emits(L2capMatchers.Data(b"a" * 44))413 assertThat(self.cert_l2cap.get_control_channel()).emits(L2capMatchers.EchoResponse())426 assertThat(self.cert_l2cap.get_control_channel()).emits(L2capMatchers.CommandReject())[all …]
48 assertThat(cert_channel).emits(72 … assertThat(cert_channel).emits(L2capMatchers.Data(b'a' * mtu), at_least_times=batch_size)85 assertThat(dut_channel).emits(113 …assertThat(cert_channel).emits(L2capMatchers.IFrame(payload=b'a' * mtu), at_least_times=tx_window_…143 assertThat(cert_channel).emits(L2capMatchers.SFrame(req_seq=(i + 1) % 64))177 assertThat(dut_channel).emits(L2capMatchers.PacketPayloadRawData(data))
102 assertThat(self._control_channel).emits(request_capture)121 assertThat(self._control_channel).emits(L2capMatchers.ConfigurationResponse(result))127 …assertThat(self._control_channel).emits(L2capMatchers.DisconnectionResponse(self._scid, self._dcid…130 …assertThat(self._control_channel).emits(L2capMatchers.DisconnectionRequest(self._dcid, self._scid))202 assertThat(self.control_channel).emits(response)213 assertThat(self.control_channel).emits(request)234 assertThat(self.control_channel).emits(request)
135 assertThat(self.dut_security.get_bond_stream()).emits(151 assertThat(self.dut_security.get_ui_stream()).emits(162 assertThat(self.cert_security.get_ui_stream()).emits(166 assertThat(self.dut_security.get_bond_stream()).emits(195 …assertThat(self.cert_security.get_ui_stream()).emits(SecurityMatchers.UiMsg(UiMsgType.DISPLAY_PAIR…206 …assertThat(self.dut_security.get_bond_stream()).emits(SecurityMatchers.BondMsg(BondMsgType.DEVICE_…229 …assertThat(self.dut_security.get_ui_stream()).emits(SecurityMatchers.UiMsg(UiMsgType.DISPLAY_PAIRI…239 …assertThat(self.dut_security.get_bond_stream()).emits(SecurityMatchers.BondMsg(BondMsgType.DEVICE_…263 …assertThat(self.dut_security.get_ui_stream()).emits(SecurityMatchers.UiMsg(UiMsgType.DISPLAY_PAIRI…274 …assertThat(self.dut_security.get_bond_stream()).emits(SecurityMatchers.BondMsg(BondMsgType.DEVICE_…[all …]
149 assertThat(self._hci_event_stream).emits(lambda msg: b'\x0e\x04\x01\x56\x0c' in msg.event)156 assertThat(self._hci_event_stream).emits(HciMatchers.LinkKeyRequest())160 assertThat(self._hci_event_stream).emits(HciMatchers.IoCapabilityRequest())166 assertThat(self._hci_event_stream).emits(HciMatchers.UserConfirmationRequest())172 assertThat(self._hci_event_stream).emits(HciMatchers.SimplePairingComplete())174 assertThat(self._hci_event_stream).emits(HciMatchers.LinkKeyNotification())180 assertThat(self._hci_event_stream).emits(HciMatchers.SimplePairingComplete())
50 assertThat(cert_acl).emits(lambda packet: b'SomeMoreAclData' in packet.data)51 assertThat(dut_acl).emits(lambda packet: b'SomeAclData' in packet.payload)66 assertThat(cert_acl).emits(lambda packet: b'SomeMoreAclData' in packet.data)67 assertThat(dut_acl).emits(lambda packet: b'SomeAclData' in packet.payload)82 assertThat(cert_acl).emits(lambda packet: b'SomeMoreAclData' in packet.data)83 assertThat(dut_acl).emits(lambda packet: b'SomeAclData' in packet.payload)99 assertThat(dut_acl).emits(lambda packet: b'Hello!' in packet.payload,
75 … assertThat(self.dut_hci.get_event_stream()).emits(lambda packet: looped_bytes in packet.event)84 assertThat(self.dut_hci.get_event_stream()).emits(151 … assertThat(self.dut_hci.get_le_event_stream()).emits(lambda packet: b'Im_A_Cert' in packet.event)161 assertThat(self.cert_hal.get_hci_event_stream()).emits(cert_conn_complete_capture)165 assertThat(self.dut_hci.get_le_event_stream()).emits(dut_conn_complete_capture)240 assertThat(self.dut_hci.get_event_stream()).emits(251 assertThat(self.cert_hal.get_acl_stream()).emits(253 assertThat(self.dut_hci.get_raw_acl_stream()).emits(309 assertThat(self.cert_hal.get_hci_event_stream()).emits(cert_connection_complete_capture)313 assertThat(self.dut_hci.get_event_stream()).emits(dut_connection_complete_capture)[all …]
83 … assertThat(advertising_event_stream).emits(lambda packet: b'Im_The_CERT' in packet.event)
171 assertThat(self.dut_le_acl).emits(lambda packet: b'SomeAclData' in packet.payload)296 assertThat(self.dut_le_acl).emits(lambda packet: b'Hello!' in packet.payload)
140 assertThat(cert_channel).emits(L2capMatchers.Data(b'hello' * 40))147 assertThat(dut_channel).emits(L2capMatchers.PacketPayloadRawData(b'\x19\x26\x08\x17'))165 …assertThat(self.cert_l2cap.get_control_channel()).emits(L2capMatchers.LeConnectionParameterUpdateR…176 assertThat(self.cert_l2cap.get_control_channel()).emits(189 assertThat(self.cert_l2cap.get_control_channel()).emits(201 assertThat(self.cert_l2cap.get_control_channel()).emits(L2capMatchers.LeCommandReject())214 assertThat(cert_channel).emits(225 assertThat(cert_channel).emits(L2capMatchers.FirstLeIFrame(b'hello' * 40, sdu_size=200))233 assertThat(cert_channel).emits(L2capMatchers.FirstLeIFrame(b'hello' * 40, sdu_size=200))245 assertThat(dut_channel).emits(L2capMatchers.PacketPayloadRawData(b'\x19\x26\x08\x17' * 2))[all …]
61 …assertThat(self._control_channel).emits(L2capMatchers.LeDisconnectionResponse(self._scid, self._dc…64 …assertThat(self._control_channel).emits(L2capMatchers.LeDisconnectionRequest(self._dcid, self._sci…113 assertThat(self.control_channel).emits(response)125 assertThat(self.control_channel).emits(response)132 assertThat(self.control_channel).emits(request)142 assertThat(self.control_channel).emits(request)148 assertThat(self.control_channel).emits(L2capMatchers.LeFlowControlCredit(channel._dcid))
153 assertThat(cert_channel).emits(L2capMatchers.Data(b'abc'))156 assertThat(le_cert_channel).emits(L2capMatchers.FirstLeIFrame(b'hello', sdu_size=5))159 assertThat(le_dut_channel).emits(L2capMatchers.PacketPayloadRawData(b'\x19\x26\x08\x17'))178 assertThat(cert_channel).emits(L2capMatchers.Data(b'abc'))181 assertThat(le_cert_channel).emits(L2capMatchers.FirstLeIFrame(b'hello', sdu_size=5))184 assertThat(le_dut_channel).emits(L2capMatchers.PacketPayloadRawData(b'\x19\x26\x08\x17'))
54 …assertThat(self.cert_hci.get_event_stream()).emits(HciMatchers.CommandComplete(OpCode.WRITE_LOCAL_…65 …assertThat(session).emits(NeighborMatchers.InquiryResult(self.cert_address), timeout=timedelta(sec…76 assertThat(session).emits(96 assertThat(session).emits(
48 …assertThat(self.remote_name_stream).emits(lambda msg: bytes(name) in msg.name, timeout=timedelta(s…
78 … assertThat(hci_event_stream).emits(lambda packet: bytes(event.Serialize()) in packet.payload)89 … assertThat(hci_event_stream).emits(lambda packet: bytes(command.Serialize()) in packet.payload)99 assertThat(hci_event_stream).emits(lambda packet: b'\x02\x0f' in packet.payload157 assertThat(hci_event_stream).emits(lambda packet: b'Im_A_Cert' in packet.payload)250 assertThat(cert_hci_event_stream).emits(payload_handle)253 assertThat(hci_event_stream).emits(payload_handle)262 assertThat(cert_acl_data_stream).emits(lambda packet: b'SomeAclData' in packet.payload)263 assertThat(acl_data_stream).emits(lambda packet: b'SomeMoreAclData' in packet.payload)
156 assertThat(self._ui_event_stream).emits(get_unique_id)170 … assertThat(self._bond_event_stream).emits(lambda event: event.message_type == expected_bond_event)180 assertThat(self._enforce_security_policy_stream).emits(
127 assertThat(self.event_stream).emits(read_bd_addr)142 assertThat(self.event_stream).emits(connection_request)151 assertThat(self.event_stream).emits(connection_complete)
261 assertThat(event_stream).emits(lambda data: data.value_ == 1)265 … assertThat(event_stream).emits(lambda data: data.value_ == 1).then(lambda data: data.value_ == 3)270 assertThat(event_stream).emits(lambda data: data.value_ == 4)279 … assertThat(event_stream).emits(lambda data: data.value_ == 1).emits(lambda data: data.value_ == 4)287 …assertThat(event_stream).emits(lambda data: data.value_ == 1, lambda data: data.value_ == 2).inOrd…291 assertThat(event_stream).emits(298 …assertThat(event_stream).emits(lambda data: data.value_ == 2, lambda data: data.value_ == 1).inOrd…307 assertThat(event_stream).emits(lambda data: data.value_ == 4,355 .emits(lambda data: data.value_ == 1)\
47 assertThat(self.connection_event_stream).emits(disconnection_complete)81 assertThat(event_stream).emits(connection_complete)
57 assertThat(self.connection_event_stream).emits(disconnection_complete)111 assertThat(event_stream).emits(connection_complete)
60 assertThat(self._ui_event_stream).emits(display_passkey_capture, timeout=timeout)
60 def emits(self, *match_fns, at_least_times=1, timeout=DEFAULT_TIMEOUT): member in EventStreamSubject