Refactor ServerRequest

[netconf.git] / restconf / restconf-nb / src / main / java / org / opendaylight / restconf / server / spi / RestconfStream.java

diff --git a/restconf/restconf-nb/src/main/java/org/opendaylight/restconf/server/spi/RestconfStream.java b/restconf/restconf-nb/src/main/java/org/opendaylight/restconf/server/spi/RestconfStream.java
index a746a98a1b5ae03e8a38ddbf59d8a61fcc57ebb1..ce66d822d554dad96cd24e81566b698d1bfc8278 100644 (file)
--- a/restconf/restconf-nb/src/main/java/org/opendaylight/restconf/server/spi/RestconfStream.java
+++ b/restconf/restconf-nb/src/main/java/org/opendaylight/restconf/server/spi/RestconfStream.java
@@ -24,8 +24,8 @@ import javax.xml.xpath.XPathExpressionException;
 import org.checkerframework.checker.lock.qual.GuardedBy;
 import org.eclipse.jdt.annotation.NonNull;
 import org.eclipse.jdt.annotation.Nullable;
-import org.opendaylight.restconf.common.errors.RestconfFuture;
 import org.opendaylight.restconf.server.api.EventStreamGetParams;
+import org.opendaylight.restconf.server.api.ServerRequest;
 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.restconf.monitoring.rev170126.restconf.state.streams.stream.Access;
 import org.opendaylight.yangtools.concepts.Registration;
 import org.opendaylight.yangtools.yang.model.api.EffectiveModelContext;
@@ -145,13 +145,13 @@ public final class RestconfStream<T> {
          * create the corresponding instance and register it.
          *
          * @param <T> Stream type
+         * @param request {@link ServerRequest} for this invocation.
          * @param restconfURI resolved {@code {+restconf}} resource name
          * @param source Stream instance
          * @param description Stream descriptiion
-         * @return A future {@link RestconfStream} instance
          * @throws NullPointerException if any argument is {@code null}
          */
-        <T> @NonNull RestconfFuture<RestconfStream<T>> createStream(URI restconfURI, Source<T> source,
+        <T> void createStream(ServerRequest<RestconfStream<T>> request, URI restconfURI, Source<T> source,
             String description);
     }