def METHOD_NAME(self):
    # Test that the TCP server can stream PDUs <= the MTU size.
    port = str(random.Random().randint(0, 30000) + 10000)
    mtu = 10000
    srcdata = tuple(x % 256 for x in range(mtu))
    data = pmt.init_u8vector(srcdata.__len__(), srcdata)
    pdu_msg = pmt.cons(pmt.PMT_NIL, data)
    self.pdu_source = blocks.message_strobe(pdu_msg, 500)
    self.pdu_send = network.socket_pdu(
        "TCP_SERVER", "localhost", port, mtu)
    self.pdu_recv = network.socket_pdu(
        "TCP_CLIENT", "localhost", port, mtu)
    self.pdu_sink = blocks.message_debug()
    self.tb.msg_connect(self.pdu_source, "strobe", self.pdu_send, "pdus")
    self.tb.msg_connect(self.pdu_recv, "pdus", self.pdu_sink, "store")
    self.tb.start()
    time.sleep(1)
    self.tb.stop()
    self.tb.wait()
    received = self.pdu_sink.get_message(0)
    received_data = pmt.cdr(received)
    msg_data = []
    for i in range(mtu):
        msg_data.append(pmt.u8vector_ref(received_data, i))
    self.assertEqual(srcdata, tuple(msg_data))