View Source K8s.Client.HTTPStream (k8s v2.4.2)
Helper functions for HTTP stream processing.
Summary
Types
@type to_lines_t() :: %{remainder: binary()}
Functions
@spec decode_json_objects(Enumerable.t(K8s.Client.Provider.http_chunk_t())) :: Enumerable.t(K8s.Client.Provider.http_chunk_t() | {:object, binary()})
@spec transform_to_lines(Enumerable.t(K8s.Client.Provider.http_chunk_t())) :: Enumerable.t(K8s.Client.Provider.http_chunk_t() | {:line, binary()})