SergejIsbrecht

  @Test
  public void connect() {
    PublishSubject<Integer> values = PublishSubject.create();

    ConnectableObservable<Integer> i$ = values.hide().mergeWith(Observable.never()).replay(1);
    Disposable d = i$.connect();

    TestObserver<Integer> test1$ = i$.test();
    values.onNext(4);

SergejIsbrecht

Linux L530 4.13.0-46-generic #51-Ubuntu SMP Tue Jun 12 12:36:29 UTC 2018 x86_64 x86_64 x86_64 GNU/Linux

Architecture:        x86_64
CPU op-mode(s):      32-bit, 64-bit
Byte Order:          Little Endian
CPU(s):              4
On-line CPU(s) list: 0-3
Thread(s) per core:  2
Core(s) per socket:  2
Socket(s):           1

SergejIsbrecht

Linux L530 4.13.0-46-generic #51-Ubuntu SMP Tue Jun 12 12:36:29 UTC 2018 x86_64 x86_64 x86_64 GNU/Linux

Architecture:        x86_64
CPU op-mode(s):      32-bit, 64-bit
Byte Order:          Little Endian
CPU(s):              4
On-line CPU(s) list: 0-3
Thread(s) per core:  2
Core(s) per socket:  2
Socket(s):           1

SergejIsbrecht

ava.nio.file.NoSuchFileException: files/ospd.txt
        at java.base/sun.nio.fs.UnixException.translateToIOException(UnixException.java:92)
        at java.base/sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:111)
        at java.base/sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:116)
        at java.base/sun.nio.fs.UnixFileSystemProvider.newFileChannel(UnixFileSystemProvider.java:178)
        at java.base/java.nio.channels.FileChannel.open(FileChannel.java:292)
        at java.base/java.nio.channels.FileChannel.open(FileChannel.java:345)
        at java.base/java.nio.file.Files.lines(Files.java:4033)
        at java.base/java.nio.file.Files.lines(Files.java:4125)
        at hu.akarnokd.comparison.Util.readScrabbleWords(Util.java:35)

SergejIsbrecht

Starting a Gradle Daemon, 3 stopped Daemons could not be reused, use --status for details

> Configure project :
[.*Scrabble.*]

> Task :compileJava UP-TO-DATE
> Task :processResources UP-TO-DATE
> Task :classes UP-TO-DATE
> Task :compileJmhJava UP-TO-DATE
> Task :processJmhResources NO-SOURCE

SergejIsbrecht

Starting a Gradle Daemon, 1 busy Daemon could not be reused, use --status for details

> Configure project :
[.*Scrabble.*]

> Task :compileJava
Note: /home/sergej/GitHub/akarnokd-misc/src/main/java/hu/akarnokd/rxjava2/RefCountGrace.java uses or overrides a deprecated API.
Note: Recompile with -Xlint:deprecation for details.
Note: /home/sergej/GitHub/akarnokd-misc/src/main/java/hu/akarnokd/enumerables/IEnumerable.java uses unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.

SergejIsbrecht

-rw-rw-r--  1 sergej sergej  75191424 Jan 13 02:16 big2.txt (Luther Bible)
Linux sergej-P50 4.18.0-13-generic #14-Ubuntu SMP Wed Dec 5 09:04:24 UTC 2018 x86_64 x86_64 x86_64 GNU/Linux
// Graal-1.0.0-RC10 OpenJDK

sergej@sergej-P50:~/Downloads$ lscpu
Architecture:        x86_64
CPU op-mode(s):      32-bit, 64-bit
Byte Order:          Little Endian
CPU(s):              8
On-line CPU(s) list: 0-7

SergejIsbrecht

SergejIsbrecht

SergejIsbrecht

package com.sergejisbrecht.reactive;

import com.google.common.annotations.Beta;
import com.google.common.annotations.VisibleForTesting;
import io.reactivex.Observable;
import io.reactivex.disposables.Disposable;
import io.reactivex.disposables.Disposables;
import io.reactivex.functions.Consumer;
import io.reactivex.subjects.PublishSubject;
import io.reactivex.subjects.Subject;