diff --git a/lib/spear/reading/stream.ex b/lib/spear/reading/stream.ex index 09fbcda..3bd4eb2 100644 --- a/lib/spear/reading/stream.ex +++ b/lib/spear/reading/stream.ex @@ -51,12 +51,16 @@ defmodule Spear.Reading.Stream do _rest} -> [] - {message, _rest} -> + {event() = message, _rest} -> Stream.unfold( %__MODULE__{state | buffer: buffer, from: message}, unfold_fn ) + {Streams.read_resp(content: {content_case, _}), _rest} + when content_case in [:last_stream_position, :first_stream_position] -> + [] + nil -> [] end