diff --git a/blocking.go b/blocking.go index 68ae4ecf..03de7f84 100644 --- a/blocking.go +++ b/blocking.go @@ -50,12 +50,6 @@ func (obs Observable[T]) BlockingFirst(ctx context.Context) (v T, err error) { wg.Wait() - select { - default: - case <-ctx.Done(): - return v, ctx.Err() - } - switch res.Kind { case KindNext: return res.Value, nil @@ -129,12 +123,6 @@ func (obs Observable[T]) BlockingLast(ctx context.Context) (v T, err error) { wg.Wait() - select { - default: - case <-ctx.Done(): - return v, ctx.Err() - } - switch res.Kind { case KindNext: return res.Value, nil @@ -225,12 +213,6 @@ func (obs Observable[T]) BlockingSingle(ctx context.Context) (v T, err error) { wg.Wait() - select { - default: - case <-ctx.Done(): - return v, ctx.Err() - } - switch res.Kind { case KindNext: return res.Value, nil