Method filter

src/main/java/groovy/concurrent/AsyncChannel.java:136–136

Returns a new channel that passes only elements matching the predicate. @param predicate the filter function @return a new filtered channel @since 6.0.0

(Predicate<T> predicate)

     * @since 6.0.0
     */
    default AsyncChannel<T> filter(Predicate<T> predicate) {
        AsyncChannel<T> out = create(getCapacity());
        AsyncSupport.getExecutor().execute(() -> {
            try {