diff --git a/bedrock/bedrock.go b/bedrock/bedrock.go index a4729e5..ca0dcd3 100644 --- a/bedrock/bedrock.go +++ b/bedrock/bedrock.go @@ -46,11 +46,11 @@ type eventstreamDecoder struct { } func (e *eventstreamDecoder) Close() error { - return nil + return e.rc.Close() } func (e *eventstreamDecoder) Err() error { - return nil + return e.err } func (e *eventstreamDecoder) Next() bool {