Empty operator

ReactiveX · Feb 15, 2020 · 3f30d5e · 3f30d5e
1 parent e09b5aa
commit 3f30d5e
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 2 deletions.
diff --git a/assert_test.go b/assert_test.go
@@ -57,10 +57,9 @@ func hasItems(items ...interface{}) rxAssert {
 	})
 }
 
-func hasNoItems(items ...interface{}) rxAssert {
+func hasNoItems() rxAssert {
 	return newAssertion(func(a *rxAssertImpl) {
 		a.checkHasNoItems = true
-		a.items = items
 	})
 }
 

diff --git a/factory.go b/factory.go
@@ -1,5 +1,13 @@
 package rxgo
 
+func Empty() Observable {
+	next := make(chan Item)
+	close(next)
+	return &observable{
+		iterable: newIterable(next),
+	}
+}
+
 func FromChannel(next <-chan Item) Observable {
 	return &observable{
 		iterable: newIterable(next),

diff --git a/factory_test.go b/factory_test.go
@@ -5,6 +5,11 @@ import (
 	"testing"
 )
 
+func Test_Empty(t *testing.T) {
+	obs := Empty()
+	assertObservable(t, context.Background(), obs, hasNoItems())
+}
+
 func Test_FromChannel(t *testing.T) {
 	next := channelValue(1, 2, 3, closeCmd)
 	obs := FromChannel(next)