1 files changed, 152 insertions, 0 deletions
diff --git a/testing/web-platform/tests/dom/observable/tentative/observable-drop.any.js b/testing/web-platform/tests/dom/observable/tentative/observable-drop.any.js
new file mode 100644
index 0000000000..4b15fedfd3
--- /dev/null
+++ b/testing/web-platform/tests/dom/observable/tentative/observable-drop.any.js
@@ -0,0 +1,152 @@
+test(() => {
+  const source = new Observable(subscriber => {
+    subscriber.next(1);
+    subscriber.next(2);
+    subscriber.next(3);
+    subscriber.next(4);
+    subscriber.complete();
+  });
+
+  const results = [];
+
+  source.drop(2).subscribe({
+    next: v => results.push(v),
+    error: e => results.push(e),
+    complete: () => results.push("complete"),
+  });
+
+  assert_array_equals(results, [3, 4, "complete"]);
+}, "drop(): Observable should skip the first n values from the source " +
+   "observable, then pass through the rest of the values and completion");
+
+test(() => {
+  const error = new Error('source error');
+  const source = new Observable(subscriber => {
+    subscriber.next(1);
+    subscriber.next(2);
+    subscriber.next(3);
+    subscriber.next(4);
+    subscriber.error(error);
+  });
+
+  const results = [];
+
+  source.drop(2).subscribe({
+    next: v => results.push(v),
+    error: e => results.push(e),
+    complete: () => results.push("complete"),
+  });
+
+  assert_array_equals(results, [3, 4, error]);
+}, "drop(): Observable passes through errors from source Observable");
+
+test(() => {
+  const error = new Error('source error');
+  const source = new Observable(subscriber => {
+    subscriber.error(error);
+    subscriber.next(1);
+  });
+
+  const results = [];
+
+  source.drop(2).subscribe({
+    next: v => results.push(v),
+    error: e => results.push(e),
+    complete: () => results.push("complete"),
+  });
+
+  assert_array_equals(results, [error]);
+}, "drop(): Observable passes through errors from source observable even " +
+   "before drop count is met");
+
+test(() => {
+  const source = new Observable(subscriber => {
+    subscriber.next(1);
+    subscriber.complete();
+  });
+
+  const results = [];
+
+  source.drop(2).subscribe({
+    next: v => results.push(v),
+    error: e => results.push(e),
+    complete: () => results.push("complete"),
+  });
+
+  assert_array_equals(results, ["complete"]);
+}, "drop(): Observable passes through completions from source observable even " +
+    "before drop count is met");
+
+test(() => {
+  let sourceTeardownCalled = false;
+  const source = new Observable(subscriber => {
+    subscriber.addTeardown(() => sourceTeardownCalled = true);
+    subscriber.next(1);
+    subscriber.next(2);
+    subscriber.next(3);
+    subscriber.next(4);
+    subscriber.next(5);
+    subscriber.complete();
+  });
+
+  const results = [];
+
+  const controller = new AbortController();
+
+  source.drop(2).subscribe({
+    next: v => {
+      results.push(v);
+      if (v === 3) {
+        controller.abort();
+      }
+    },
+    error: (e) => results.push(e),
+    complete: () => results.push("complete"),
+  }, {signal: controller.signal});
+
+  assert_true(sourceTeardownCalled,
+      "Aborting outer observable unsubscribes the source observable");
+  assert_array_equals(results, [3]);
+}, "drop(): Unsubscribing from the Observable returned by drop() also " +
+    "unsubscribes from the source Observable");
+
+test(() => {
+  const source = new Observable(subscriber => {
+    subscriber.next(1);
+    subscriber.next(2);
+    subscriber.next(3);
+    subscriber.complete();
+  });
+
+  const results = [];
+
+  source.drop(0).subscribe({
+    next: v => results.push(v),
+    error: e => results.push(e),
+    complete: () => results.push("complete"),
+  });
+
+  assert_array_equals(results, [1, 2, 3, "complete"],
+      "Source Observable is mirrored");
+}, "drop(): A drop amount of 0 simply mirrors the source Observable");
+
+test(() => {
+  const source = new Observable(subscriber => {
+    subscriber.next(1);
+    subscriber.next(2);
+    subscriber.next(3);
+    subscriber.complete();
+  });
+
+  const results = [];
+
+  // Passing `-1` here is subject to the Web IDL integer conversion semantics,
+  // which converts the drop amount to the maximum of `18446744073709551615`.
+  source.drop(-1).subscribe({
+    next: v => results.push(v),
+    error: e => results.push(e),
+    complete: () => results.push("complete"),
+  });
+
+  assert_array_equals(results, ["complete"], "Source Observable is mirrored");
+}, "drop(): Passing negative value wraps to maximum value ");