update(Blocking*): remove context cancellation detection

b97tsk · Jan 21, 2024 · abc8fa2 · abc8fa2
1 parent fe5c143
commit abc8fa2
Showing 1 changed file with 0 additions and 18 deletions.
diff --git 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