JdZddlmZddlmZddlmZddlmZddlZddlZddlZdZ ejrdZ yejrd Z yy) z Read JSON objects from a stream.)absolute_import)division)print_function)unicode_literalsNc#Kt|D]/}|stjtj|1yw)zRead the events from the skaffold event stream. Args: file_obj: A File object. Yields: Event dicts from the JSON payloads. N)_ReadStreamingLinesjsonloadssix ensure_strfile_objlines 2lib/googlecloudsdk/command_lib/code/json_stream.pyReadJsonStreamrs5"(+d  **S^^D) **,s?Ac#Ktjt5|D]}| dddy#1swYyxYww)N) contextlibsuppressConnectionResetErrorr s rrr,s/   1 2$  3 2 2s> 2 >;>c#\K d} |jd}|sy|dk(rn||z } |(w)a*Python 2 compatibility with py3's streaming behavior. If file_obj is an HTTPResponse, iterating over lines blocks until a buffer is full. Args: file_obj: A file-like object, including HTTPResponse. Yields: Lines, like iter(file_obj) but without buffering stalls. N )read)rrbytes rrr3sK  d }}Q  5=     j s*,) __doc__ __future__rrrrrr r rPY3rPY2rrr!sE'&%'  +77  WW r