def __init__(self, stream, max_buffer_size, test_small_buffer=False):
    self._orig_fp = stream

    if not test_small_buffer and max_buffer_size < GetJsonResumableChunkSize():
      raise CommandException('Resumable streaming upload created with buffer '
                             'size %s, JSON resumable upload chunk size %s. '
                             'Buffer size must be >= JSON resumable upload '
                             'chunk size to ensure that uploads can be '
                             'resumed.' % (max_buffer_size,
                                           GetJsonResumableChunkSize()))

    self._max_buffer_size = max_buffer_size
    self._buffer = collections.deque()
    self._buffer_start = 0
    self._buffer_end = 0
    self._position = 0
Testing a get
dataset/ETHPy150Open GoogleCloudPlatform/gsutil/gslib/resumable_streaming_upload.py/ResumableStreamingJsonUploadWrapper.__init__--crossover with--dataset/ETHPy150Open openshift/openshift-ansible/test/units/yedit_test.py/YeditTest.test_load