def METHOD_NAME(a, b, start=False, n=1000, msg=1):
    sub = Sub(a)
    pub = Pub(b)
    while not pub.subscribers:
        sleep(0.01)
    if start:
        pub.put(msg)  # other sub may not have started yet
    for _ in range(n):
        msg = next(sub)
        pub.put(msg)
        # if i % 100 == 0:
        #     print(a, b, i)
    return n