File tree 10 files changed +110
-0
lines changed
main/java/org/reactivestreams/example/unicast
test/java/org/reactivestreams/example/unicast
10 files changed +110
-0
lines changed Original file line number Diff line number Diff line change
1
+ /************************************************************************
2
+ * Licensed under Public Domain (CC0) *
3
+ * *
4
+ * To the extent possible under law, the person who associated CC0 with *
5
+ * this code has waived all copyright and related or neighboring *
6
+ * rights to this code. *
7
+ * *
8
+ * You should have received a copy of the CC0 legalcode along with this *
9
+ * work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10
+ ************************************************************************/
11
+
1
12
package org .reactivestreams .example .unicast ;
2
13
3
14
import org .reactivestreams .Publisher ;
Original file line number Diff line number Diff line change
1
+ /************************************************************************
2
+ * Licensed under Public Domain (CC0) *
3
+ * *
4
+ * To the extent possible under law, the person who associated CC0 with *
5
+ * this code has waived all copyright and related or neighboring *
6
+ * rights to this code. *
7
+ * *
8
+ * You should have received a copy of the CC0 legalcode along with this *
9
+ * work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10
+ ************************************************************************/
11
+
1
12
package org .reactivestreams .example .unicast ;
2
13
3
14
import org .reactivestreams .Subscriber ;
Original file line number Diff line number Diff line change
1
+ /************************************************************************
2
+ * Licensed under Public Domain (CC0) *
3
+ * *
4
+ * To the extent possible under law, the person who associated CC0 with *
5
+ * this code has waived all copyright and related or neighboring *
6
+ * rights to this code. *
7
+ * *
8
+ * You should have received a copy of the CC0 legalcode along with this *
9
+ * work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10
+ ************************************************************************/
11
+
1
12
package org .reactivestreams .example .unicast ;
2
13
3
14
import java .util .Iterator ;
Original file line number Diff line number Diff line change
1
+ /************************************************************************
2
+ * Licensed under Public Domain (CC0) *
3
+ * *
4
+ * To the extent possible under law, the person who associated CC0 with *
5
+ * this code has waived all copyright and related or neighboring *
6
+ * rights to this code. *
7
+ * *
8
+ * You should have received a copy of the CC0 legalcode along with this *
9
+ * work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10
+ ************************************************************************/
11
+
1
12
package org .reactivestreams .example .unicast ;
2
13
3
14
import java .util .Collections ;
Original file line number Diff line number Diff line change
1
+ /************************************************************************
2
+ * Licensed under Public Domain (CC0) *
3
+ * *
4
+ * To the extent possible under law, the person who associated CC0 with *
5
+ * this code has waived all copyright and related or neighboring *
6
+ * rights to this code. *
7
+ * *
8
+ * You should have received a copy of the CC0 legalcode along with this *
9
+ * work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10
+ ************************************************************************/
11
+
1
12
package org .reactivestreams .example .unicast ;
2
13
3
14
import org .reactivestreams .Subscriber ;
Original file line number Diff line number Diff line change
1
+ /************************************************************************
2
+ * Licensed under Public Domain (CC0) *
3
+ * *
4
+ * To the extent possible under law, the person who associated CC0 with *
5
+ * this code has waived all copyright and related or neighboring *
6
+ * rights to this code. *
7
+ * *
8
+ * You should have received a copy of the CC0 legalcode along with this *
9
+ * work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10
+ ************************************************************************/
11
+
1
12
package org .reactivestreams .example .unicast ;
2
13
3
14
import org .reactivestreams .Publisher ;
Original file line number Diff line number Diff line change
1
+ /************************************************************************
2
+ * Licensed under Public Domain (CC0) *
3
+ * *
4
+ * To the extent possible under law, the person who associated CC0 with *
5
+ * this code has waived all copyright and related or neighboring *
6
+ * rights to this code. *
7
+ * *
8
+ * You should have received a copy of the CC0 legalcode along with this *
9
+ * work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10
+ ************************************************************************/
11
+
1
12
package org .reactivestreams .example .unicast ;
2
13
3
14
import java .lang .Override ;
Original file line number Diff line number Diff line change
1
+ /************************************************************************
2
+ * Licensed under Public Domain (CC0) *
3
+ * *
4
+ * To the extent possible under law, the person who associated CC0 with *
5
+ * this code has waived all copyright and related or neighboring *
6
+ * rights to this code. *
7
+ * *
8
+ * You should have received a copy of the CC0 legalcode along with this *
9
+ * work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10
+ ************************************************************************/
11
+
1
12
package org .reactivestreams .example .unicast ;
2
13
3
14
import org .reactivestreams .Subscriber ;
Original file line number Diff line number Diff line change
1
+ /************************************************************************
2
+ * Licensed under Public Domain (CC0) *
3
+ * *
4
+ * To the extent possible under law, the person who associated CC0 with *
5
+ * this code has waived all copyright and related or neighboring *
6
+ * rights to this code. *
7
+ * *
8
+ * You should have received a copy of the CC0 legalcode along with this *
9
+ * work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10
+ ************************************************************************/
11
+
1
12
package org .reactivestreams .example .unicast ;
2
13
3
14
import org .reactivestreams .Subscriber ;
Original file line number Diff line number Diff line change
1
+ /************************************************************************
2
+ * Licensed under Public Domain (CC0) *
3
+ * *
4
+ * To the extent possible under law, the person who associated CC0 with *
5
+ * this code has waived all copyright and related or neighboring *
6
+ * rights to this code. *
7
+ * *
8
+ * You should have received a copy of the CC0 legalcode along with this *
9
+ * work. If not, see <http://creativecommons.org/publicdomain/zero/1.0/>.*
10
+ ************************************************************************/
11
+
1
12
package org .reactivestreams .example .unicast ;
2
13
3
14
import org .reactivestreams .Publisher ;
You can’t perform that action at this time.
0 commit comments