Changeset 105 for java/main/src/main/java/com/framsticks/communication/ClientSideManagedConnection.java
- Timestamp:
- 09/10/13 21:11:41 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
java/main/src/main/java/com/framsticks/communication/ClientSideManagedConnection.java
r103 r105 9 9 import com.framsticks.communication.queries.UseRequest; 10 10 import com.framsticks.communication.queries.VersionRequest; 11 import com.framsticks.core.Path;12 11 import com.framsticks.params.ListSource; 12 import com.framsticks.structure.Path; 13 13 import com.framsticks.util.*; 14 14 import com.framsticks.util.dispatching.AtOnceDispatcher; 15 15 import com.framsticks.util.dispatching.Dispatcher; 16 16 import com.framsticks.util.dispatching.Dispatching; 17 import com.framsticks.util.dispatching. ExceptionResultHandler;17 import com.framsticks.util.dispatching.FutureHandler; 18 18 import com.framsticks.util.dispatching.Future; 19 import com.framsticks.util.dispatching.FutureHandler;20 19 import com.framsticks.util.dispatching.JoinableState; 21 20 import com.framsticks.util.lang.Casting; … … 195 194 } 196 195 197 private void sendNextUseRequest(final Iterator<String> featuresIterator, final Future <Void> future) {196 private void sendNextUseRequest(final Iterator<String> featuresIterator, final FutureHandler<Void> future) { 198 197 if (!featuresIterator.hasNext()) { 199 198 future.pass(null); … … 214 213 } 215 214 216 private void sendQueryVersion(final int version, final Future <Void> future) {215 private void sendQueryVersion(final int version, final FutureHandler<Void> future) { 217 216 send(new VersionRequest().version(version), new ClientSideResponseFuture(future) { 218 217 @Override … … 335 334 } 336 335 337 final Future <File> future = new Future<File>() {336 final FutureHandler<File> future = new FutureHandler<File>() { 338 337 339 338 protected void send(final File result) { … … 415 414 } 416 415 417 protected final Exception ResultHandler closeOnFailure = new ExceptionResultHandler() {416 protected final ExceptionHandler closeOnFailure = new ExceptionHandler() { 418 417 419 418 @Override … … 428 427 startClientConnection(this); 429 428 430 sendQueryVersion(1, new Future Handler<Void>(closeOnFailure) {429 sendQueryVersion(1, new Future<Void>(closeOnFailure) { 431 430 432 431 @Override … … 451 450 protected final Map<String, EventListener<File>> registeredListeners = new HashMap<>(); 452 451 453 public <C> void addListener(String path, final EventListener<File> listener, final Dispatcher<C> dispatcher, final Future <Void> future) {452 public <C> void addListener(String path, final EventListener<File> listener, final Dispatcher<C> dispatcher, final FutureHandler<Void> future) { 454 453 send(new RegisterRequest().path(path), dispatcher, new ClientSideResponseFuture(future) { 455 454 @Override … … 463 462 } 464 463 465 public <C> void removeListener(EventListener<File> listener, final Dispatcher<C> dispatcher, final Future <Void> future) {464 public <C> void removeListener(EventListener<File> listener, final Dispatcher<C> dispatcher, final FutureHandler<Void> future) { 466 465 String eventPath = null; 467 466 synchronized (registeredListeners) {
Note: See TracChangeset
for help on using the changeset viewer.