@peer_required
@api_request
async def request_mempool_transactions(self, request: full_node_protocol.RequestMempoolTransactions, peer: ws.WSChiaConnection) -> Optional[Message]:
    received_filter = PyBIP158(bytearray(request.filter))
    items: List[MempoolItem] = (await self.full_node.mempool_manager.get_items_not_in_filter(received_filter))
    for item in items:
        transaction = full_node_protocol.RespondTransaction(item.spend_bundle)
        msg = make_msg(ProtocolMessageTypes.respond_transaction, transaction)
        (await peer.send_message(msg))
    return None
@peer_required
@api_request
async def request_mempool_transactions(self, request: full_node_protocol.RequestMempoolTransactions, peer: ws.WSChiaConnection) -> Optional[Message]:
    received_filter = PyBIP158(bytearray(request.filter))
    items: List[MempoolItem] = (await self.full_node.mempool_manager.get_items_not_in_filter(received_filter))
    for item in items:
        transaction = full_node_protocol.RespondTransaction(item.spend_bundle)
        msg = make_msg(ProtocolMessageTypes.respond_transaction, transaction)
        (await peer.send_message(msg))
    return None