@@ -0,0 +1,428 @@
+package com.github.davidmoten.rtree;%0A%0Aimport rx.Observable.OnSubscribe;%0Aimport rx.Subscriber;%0A%0Apublic class OnSubscribeEntries implements OnSubscribe%3CEntry%3E %7B%0A%0A%09private final Node node;%0A%0A%09public OnSubscribeEntries(Node node) %7B%0A%09%09this.node = node;%0A%09%7D%0A%0A%09@Override%0A%09public void call(Subscriber%3C? super Entry%3E subscriber) %7B%0A%09%09node.entries(subscriber);%0A%09%09if (subscriber.isUnsubscribed())%0A%09%09%09return;%0A%09%09subscriber.onCompleted();%0A%09%7D%0A%0A%7D%0A

use rx