<commit_before>import pytest

from zeroless import (bind, connect)

@pytest.fixture(scope="module")
def listen_for_push():
    return bind(port=7891).pull()

@pytest.fixture(scope="module")
def push():
    return connect(port=7891).push()

class TestPushPull:
    def test_distribute(self, push, listen_for_push):
        msg = b'msg'

        push(msg)
        result = next(listen_for_push)
        assert result == msg

    def test_distribute_multipart(self, push, listen_for_push):
        msg1 = b'msg1'
        msg2 = b'msg2'

        push(msg1, msg2)
        result = next(listen_for_push)
        assert result == [msg1, msg2]

    def test_multiple_distribute(self, push, listen_for_push):
        msgs = [b'msg' + bytes(i) for i in range(10)]

        for msg in msgs:
            push(msg)
            result = next(listen_for_push)
            assert result == msg

    def test_multiple_distribute_multipart(self, push, listen_for_push ):
        msgs1 = [b'msg1' + bytes(i) for i in range(10)]
        msgs2 = [b'msg2' + bytes(i) for i in range(10)]

        for msg1, msg2 in zip(msgs1, msgs2):
            push(msg1, msg2)
            result = next(listen_for_push)
            assert result == [msg1, msg2]
<commit_msg>Removed an unnecessary space in the test_pushpull file.<commit_after>import pytest

from zeroless import (bind, connect)

@pytest.fixture(scope="module")
def listen_for_push():
    return bind(port=7891).pull()

@pytest.fixture(scope="module")
def push():
    return connect(port=7891).push()

class TestPushPull:
    def test_distribute(self, push, listen_for_push):
        msg = b'msg'

        push(msg)
        result = next(listen_for_push)
        assert result == msg

    def test_distribute_multipart(self, push, listen_for_push):
        msg1 = b'msg1'
        msg2 = b'msg2'

        push(msg1, msg2)
        result = next(listen_for_push)
        assert result == [msg1, msg2]

    def test_multiple_distribute(self, push, listen_for_push):
        msgs = [b'msg' + bytes(i) for i in range(10)]

        for msg in msgs:
            push(msg)
            result = next(listen_for_push)
            assert result == msg

    def test_multiple_distribute_multipart(self, push, listen_for_push):
        msgs1 = [b'msg1' + bytes(i) for i in range(10)]
        msgs2 = [b'msg2' + bytes(i) for i in range(10)]

        for msg1, msg2 in zip(msgs1, msgs2):
            push(msg1, msg2)
            result = next(listen_for_push)
            assert result == [msg1, msg2]

{'fraction_non_alphanumeric': 0.1117296222664016, 'fraction_numerical': 0.027037773359840953, 'mean_word_length': 2.646376811594203, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 3, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '5073659', 'n_tokens_mistral': 876, 'n_tokens_neox': 851, 'n_words': 207}