'Test cleaning of pending bytes'

@blocking_call_on_reactor_thread
@inlineCallbacks
def test_cleanup_pending_bytes(self):

    (node,) = (yield self.create_nodes(1))
    node.community.pending_bytes['a'] = 1234
    self.assertIn('a', node.community.pending_bytes)
    node.community.cleanup_pending('a')
    self.assertNotIn('a', node.community.pending_bytes)
