def test_channel_request_with_messages(self):
    self._mock_channel_service_stub.set_messages({'a': ['hello']})
    environ = _build_poll_environ('a')
    expected_headers = {
        'Cache-Control': 'no-cache',
        'Content-Length': '5',
        'Content-Type': 'application/json',
    }
    self.assertResponse('200 OK', expected_headers, 'hello',
                        channel.application, environ)
Set the high-water mark in the current context.
dataset/ETHPy150Open AppScale/appscale/AppServer/google/appengine/tools/devappserver2/channel_test.py/DevAppserverChannelTest.test_channel_request_with_messages--crossover with--dataset/ETHPy150Open dpkp/kafka-python/kafka/context.py/OffsetCommitContext.mark