New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add the SkipWhile operator to Publisher #2542
Add the SkipWhile operator to Publisher #2542
Conversation
Motivation: It's useful to be able to skip elements of a stream until a predicate fails but that isn't yet supported in Servicetalk. Modifications: Add the SkipWhile operator to the Servicetalk Publisher class. Result: SkipWhile is now supported.
@@ -297,7 +297,7 @@ If HTTP/1.x protocol is configured ServiceTalk always fallbacks to it if the pee | |||
IMPORTANT: Your runtime must support ALPN extension for TLS. The recommended way is to use OpenSSL provider and add | |||
link:https://netty.io/wiki/forked-tomcat-native.html#artifacts[netty-tcnative] artifact to the classpath. If OpenSSL is | |||
not available, make sure your JVM version supports ALPN or use | |||
link:https://www.eclipse.org/jetty/documentation/current/alpn-chapter.html[another provider] that supports it. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The current link results in a 404.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
suggestion on test but lgtm!
fyi when adding new operators we usually add a ReactiveStreams TCK test (see PublisherFilterTckTest). Looks like I didn't do this for Publisher.distinct()
which is similar but not sure if it was an omission or bcz TCK wouldn't fail if duplicates aren't emitted.
...talk-concurrent-api/src/test/java/io/servicetalk/concurrent/api/publisher/SkipWhileTest.java
Outdated
Show resolved
Hide resolved
...talk-concurrent-api/src/test/java/io/servicetalk/concurrent/api/publisher/SkipWhileTest.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
🚀
Motivation:
It's useful to be able to skip elements of a stream until a predicate fails but that isn't yet supported in Servicetalk.
Modifications:
Add the SkipWhile operator to the Servicetalk Publisher class.
Result:
SkipWhile is now supported.