final def !=(arg0: Any): Boolean

Definition Classes: AnyRef → Any

final def ##(): Int

Definition Classes: AnyRef → Any

final def ==(arg0: Any): Boolean

Definition Classes: AnyRef → Any

final def asInstanceOf[T0]: T0

Definition Classes: Any

def authenticate(token: String): Future[Source[AuthMessage, SourceQueueWithComplete[Any]]]

Scala API.

Scala API. Mock the Datasync 'authenticate' method. This method is called by any application under test instead of DatasyncClient.authenticate method.

token: a token used to authenticate on that application.
returns: a Future[Source[AuthMessage, SourceQueueWithComplete[Any]]] that may fail if operation fails.

Definition Classes: MockDatasyncClient → DatasyncClient

def authenticateJ(token: String): CompletionStage[Source[AuthMessage, SourceQueueWithComplete[Any]]]

Java API.

Java API. Mock the Datasync 'authenticateJ' method. This method is called by any application under test instead of DatasyncClient.authenticateJ method.

token: a token used to authenticate on that application.
returns: a CompletionStage<Source<AuthMessage, SourceQueueWithComplete<Any>>> that may fail if operation fails.

Definition Classes: MockDatasyncClient → DatasyncClient

def clone(): AnyRef

Attributes: protected[java.lang]
Definition Classes: AnyRef
Annotations: @native() @throws( ... )

def close(): Unit

Ends this client's Web Socket connection to Datasync, and therefore cancels all pending operations if any.

Definition Classes: MockDatasyncClient → DatasyncClient

def connectionStatus(): Future[Source[CnxStatusMessage, SourceQueueWithComplete[Any]]]

Scala API.

Scala API. Mock the 'connectionStatus' method. This method is called by any application under test instead of DatasyncClient.connectionStatus method. As this is useless in a mock, it always return a successful empty Source.

returns: a Future[Source[CnxStatusMessage, SourceQueueWithComplete[Any]]] that may fail if operation fails.

Definition Classes: MockDatasyncClient → DatasyncClient

def connectionStatusJ(): CompletionStage[Source[CnxStatusMessage, SourceQueueWithComplete[Any]]]

Java API.

Java API. Mock the 'connectionStatus' method. This method is called by any application under test instead of DatasyncClient.connectionStatus method. As this is useless in a mock, it always return a successful empty Source.

returns: a CompletionStage<Source<CnxStatusMessage, SourceQueueWithComplete<Any>>> that may fail if operation fails.

Definition Classes: MockDatasyncClient → DatasyncClient

final def eq(arg0: AnyRef): Boolean

Definition Classes: AnyRef

def equals(arg0: Any): Boolean

Definition Classes: AnyRef → Any

def finalize(): Unit

Attributes: protected[java.lang]
Definition Classes: AnyRef
Annotations: @throws( classOf[java.lang.Throwable] )

final def getClass(): Class[_]

Definition Classes: AnyRef → Any
Annotations: @native()

def hashCode(): Int

Definition Classes: AnyRef → Any
Annotations: @native()

def invalidate_authentication: Future[Unit]

Scala API.

Scala API. Mock the Datasync 'invalidate_authentication' method. This method is called by any application under test instead of DatasyncClient.invalidate_authentication method.

returns: a Future[Unit] that may fail if operation fails.

Definition Classes: MockDatasyncClient → DatasyncClient

def invalidate_authenticationJ: CompletionStage[Unit]

Java API.

Java API. Mock the Datasync 'invalidate_authenticationJ' method. This method is called by any application under test instead of DatasyncClient.invalidate_authenticationJ method.

returns: a CompletionStage<BoxedUnit> that may fail if operation fails.

Definition Classes: MockDatasyncClient → DatasyncClient

final def isInstanceOf[T0]: Boolean

Definition Classes: Any

def listen(path: String, sendCache: Boolean): Future[Source[ListenMessage, SourceQueueWithComplete[Any]]]

Scala API.

Scala API. Mock the Datasync 'listen' method. This method is called by any application under test instead of DatasyncClient.listen method.

path: the path where to get notifications, formatted as "some/path/where/to/get notifications".
sendCache: if true, returned Source receives a first UpdateMessage notification containing data stored on the path. Defaults to true.
returns: a Future[Source[ListenMessage, SourceQueueWithComplete[Any]]]

Definition Classes: MockDatasyncClient → DatasyncClient

def listenJ(path: String): CompletionStage[Source[ListenMessage, SourceQueueWithComplete[Any]]]

Java API.

Java API. Mock the Datasync 'listenJ' method. This method is called by any application under test instead of DatasyncClient.listenJ method.

path: the path where to get notifications, formatted as "some/path/where/to/get notifications".
returns: a CompletionStage<Source<ListenMessage, SourceQueueWithComplete<Any>>>

Definition Classes: MockDatasyncClient → DatasyncClient

def listenJ(path: String, sendCache: Boolean): CompletionStage[Source[ListenMessage, SourceQueueWithComplete[Any]]]

Java API.

Java API. Mock the Datasync 'listenJ' method. This method is called by any application under test instead of DatasyncClient.listenJ method.

path: the path where to get notifications, formatted as "some/path/where/to/get notifications".
sendCache: if true, returned Source receives a first UpdateMessage notification containing data stored on the path.
returns: a CompletionStage<Source<ListenMessage, SourceQueueWithComplete<Any>>>

Definition Classes: MockDatasyncClient → DatasyncClient

lazy val logger: Logger

Attributes: protected
Definition Classes: LazyLogging
Annotations: @volatile()

def mockAuthenticate(): Unit

Scala API.

Scala API. Define successful authentication behavior for any token, where given response is sent immediately.

def mockAuthenticate(delay: Long): Unit

Scala API.

Scala API. Define successful authentication behavior for any token.

delay: a Long representing the delay in milliseconds before response should be sent.

def mockAuthenticate(response: (List[AuthMessage], String)): Unit

Scala API.

Scala API. Define authentication behavior for any token, where given response is sent immediately.

response: a (List[AuthMessage], String) tuple that should be null to remove some existing authentication behavior, or should define the expected authentication process for this token. First element of this tuple represents successful response, second one the error message of a failing response.

def mockAuthenticate(response: (List[AuthMessage], String), delay: Long): Unit

Scala API.

Scala API. Define authentication behavior for any token.

response: a (List[AuthMessage], String) tuple that should be null to remove some existing authentication behavior, or should define the expected authentication process for this token. First element of this tuple represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockAuthenticate(token: String): Unit

Scala API.

Scala API. Define successful authentication behavior for a given token, where given response is sent immediately.

token: a non empty String.

def mockAuthenticate(token: String, delay: Long): Unit

Scala API.

Scala API. Define successful authentication behavior for a given token.

token: a non empty String.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockAuthenticate(token: String, response: (List[AuthMessage], String)): Unit

Scala API.

Scala API. Define authentication behavior for a given token, where given response is sent immediately.

token: a non empty String.
response: a (List[AuthMessage], String) tuple that should be null to remove some existing authentication behavior, or should define the expected authentication process for this token. First element of this tuple represents successful response, second one the error message of a failing response.

def mockAuthenticate(token: String, response: (List[AuthMessage], String), delay: Long): Unit

Scala API.

Scala API. Define authentication behavior for a given token.

token: a non empty String.
response: a (List[AuthMessage], String) tuple that should be null to remove some existing authentication behavior, or should define the expected authentication process for this token. First element of this tuple represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockAuthenticateJ(): Unit

Java API.

Java API. Define successful authentication behavior for any token, where given response is sent immediately.

def mockAuthenticateJ(delay: Long): Unit

Java API.

Java API. Define successful authentication behavior for any token.

delay: a Long representing the delay in milliseconds before response should be sent.

def mockAuthenticateJ(response: Pair[List[AuthMessage], String]): Unit

Java API.

Java API. Define authentication behavior for any token, where given response is sent immediately.

response: a Pair<List<AuthMessage>, String> that should be null to remove some existing authentication behavior, or should define the expected authentication process for this token. First element of this pair represents successful response, second one the error message of a failing response.

def mockAuthenticateJ(response: Pair[List[AuthMessage], String], delay: Long): Unit

Java API.

Java API. Define authentication behavior for any token.

response: a Pair<List<AuthMessage>, String> that should be null to remove some existing authentication behavior, or should define the expected authentication process for this token. First element of this pair represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockAuthenticateJ(token: String): Unit

Java API.

Java API. Define successful authentication behavior for a given token, where given response is sent immediately.

token: a non empty String.

def mockAuthenticateJ(token: String, delay: Long): Unit

Java API.

Java API. Define successful authentication behavior for a given token.

token: a non empty String.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockAuthenticateJ(token: String, response: Pair[List[AuthMessage], String]): Unit

Java API.

Java API. Define authentication behavior for a given token, where given response is sent immediately.

token: a non empty String.
response: a Pair<List<AuthMessage>, String> that should be null to remove some existing authentication behavior, or should define the expected authentication process for this token. First element of this pair represents successful response, second one the error message of a failing response.

def mockAuthenticateJ(token: String, response: Pair[List[AuthMessage], String], delay: Long): Unit

Java API.

Java API. Define authentication behavior for a given token.

token: a non empty String.
response: a Pair<List<AuthMessage>, String> that should be null to remove some existing authentication behavior, or should define the expected authentication process for this token. First element of this pair represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockInvalidateAuthentication(): Unit

Scala API.

Scala API. Define successful invalidate authentication behavior, where response is sent immediately.

def mockInvalidateAuthentication(delay: Long): Unit

Scala API.

Scala API. Define successful invalidate authentication behavior.

delay: a Long representing the delay in milliseconds before response should be sent.

def mockInvalidateAuthentication(response: (AnyRef, String)): Unit

Scala API.

Scala API. Define invalidate authentication behavior, where given response is sent immediately.

response: a (AnyRef, String) tuple that should be null to remove some existing invalidate authentication behavior, or should define the expected invalidate authentication process. First element of this tuple represents successful response, second one the error message of a failing response.

def mockInvalidateAuthentication(response: (AnyRef, String), delay: Long): Unit

Scala API.

Scala API. Define invalidate authentication behavior.

response: a (AnyRef, String) tuple that should be null to remove some existing invalidate authentication behavior, or should define the expected invalidate authentication process. First element of this tuple represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockInvalidateAuthenticationJ(): Unit

Java API.

Java API. Define successful invalidate authentication behavior, where response is sent immediately.

def mockInvalidateAuthenticationJ(delay: Long): Unit

Java API.

Java API. Define successful invalidate authentication behavior.

delay: a Long representing the delay in milliseconds before response should be sent.

def mockInvalidateAuthenticationJ(response: Pair[AnyRef, String]): Unit

Java API.

Java API. Define invalidate authentication behavior, where given response is sent immediately.

response: a Pair<Object, String> that should be null to remove some existing invalidate authentication behavior, or should define the expected invalidate authentication process. First element of this pair represents successful response, second one the error message of a failing response.

def mockInvalidateAuthenticationJ(response: Pair[AnyRef, String], delay: Long): Unit

Java API.

Java API. Define invalidate authentication behavior.

response: a Pair<Object, String> that should be null to remove some existing invalidate authentication behavior, or should define the expected invalidate authentication process. First element of this pair represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockListen(): Unit

Scala API.

Scala API. Define successful listen behavior for any path, where given response is sent immediately.

def mockListen(delay: Long): Unit

Scala API.

Scala API. Define successful listen behavior for any path.

delay: a Long representing the delay in milliseconds before response should be sent.

def mockListen(response: (List[ListenMessage], String)): Unit

Scala API.

Scala API. Define listen behavior for any path, where given response is sent immediately.

response: a (List[ListenMessage], String) tuple that should be null to remove some existing listen behavior, or should define the expected listen process for this path. First element of this tuple represents successful response, second one the error message of a failing response.

def mockListen(response: (List[ListenMessage], String), delay: Long): Unit

Scala API.

Scala API. Define listen behavior for any path.

response: a (List[ListenMessage], String) tuple that should be null to remove some existing listen behavior, or should define the expected listen process for this path. First element of this tuple represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockListen(path: String): Unit

Define successful listen behavior for a given path, where given response is sent immediately.

path: a non empty String, formatted as "some/path/where/to/listen".

def mockListen(path: String, delay: Long): Unit

Scala API.

Scala API. Define successful listen behavior for a given path.

path: a non empty String, formatted as "some/path/where/to/listen".
delay: a Long representing the delay in milliseconds before response should be sent.

def mockListen(path: String, response: (List[ListenMessage], String)): Unit

Scala API.

Scala API. Define listen behavior for a given path, where given response is sent immediately.

path: a non empty String, formatted as "some/path/where/to/listen".
response: a (List[ListenMessage], String) tuple that should be null to remove some existing listen behavior, or should define the expected listen process for this path. First element of this tuple represents successful response, second one the error message of a failing response.

def mockListen(path: String, response: (List[ListenMessage], String), delay: Long): Unit

Scala API.

Scala API. Define listen behavior for a given path.

path: a non empty String, formatted as "some/path/where/to/listen".
response: a (List[ListenMessage], String) tuple that should be null to remove some existing listen behavior, or should define the expected listen process for this path. First element of this tuple represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockListenJ(): Unit

Java API.

Java API. Define successful listen behavior for any path, where given response is sent immediately.

def mockListenJ(delay: Long): Unit

Java API.

Java API. Define successful listen behavior for any path.

delay: a Long representing the delay in milliseconds before response should be sent.

def mockListenJ(response: Pair[List[ListenMessage], String]): Unit

Java API.

Java API. Define listen behavior for any path, where given response is sent immediately.

response: a Pair<List<ListenMessage>, String> that should be null to remove some existing listen behavior, or should define the expected listen process for this path. First element of this pair represents successful response, second one the error message of a failing response.

def mockListenJ(response: Pair[List[ListenMessage], String], delay: Long): Unit

Java API.

Java API. Define listen behavior for any path.

response: a Pair<List<ListenMessage>, String> that should be null to remove some existing listen behavior, or should define the expected listen process for this path. First element of this pair represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockListenJ(path: String): Unit

Java API.

Java API. Define successful listen behavior for a given path, where given response is sent immediately.

path: a non empty String, formatted as "some/path/where/to/listen".

def mockListenJ(path: String, delay: Long): Unit

Java API.

Java API. Define successful listen behavior for a given path.

path: a non empty String, formatted as "some/path/where/to/listen".
delay: a Long representing the delay in milliseconds before response should be sent.

def mockListenJ(path: String, response: Pair[List[ListenMessage], String]): Unit

Java API.

Java API. Define listen behavior for a given path, where given response is sent immediately.

path: a non empty String, formatted as "some/path/where/to/listen".
response: a Pair<List<ListenMessage>, String> that should be null to remove some existing listen behavior, or should define the expected listen process for this path. First element of this pair represents successful response, second one the error message of a failing response.

def mockListenJ(path: String, response: Pair[List[ListenMessage], String], delay: Long): Unit

Java API.

Java API. Define listen behavior for a given path.

path: a non empty String, formatted as "some/path/where/to/listen".
response: a Pair<List<ListenMessage>, String> that should be null to remove some existing listen behavior, or should define the expected listen process for this path. First element of this pair represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockOnce(): Unit

Scala API.

Scala API. Define successful once behavior for any path, where given response is sent immediately.

def mockOnce(delay: Long): Unit

Scala API.

Scala API. Define successful once behavior for any path.

delay: a Long representing the delay in milliseconds before response should be sent.

def mockOnce(response: (String, String)): Unit

Scala API.

Scala API. Define once behavior for any path, where given response is sent immediately.

response: a (String, String) tuple that should be null to remove some existing once behavior, or should define the expected once process for this path. First element of this tuple represents successful response, second one the error message of a failing response.

def mockOnce(response: (String, String), delay: Long): Unit

Scala API.

Scala API. Define once behavior for any path.

response: a (String, String) tuple that should be null to remove some existing once behavior, or should define the expected once process for this path. First element of this tuple represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockOnce(path: String): Unit

Scala API.

Scala API. Define successful once behavior for a given path, where given response is sent immediately.

path: a non empty String, formatted as "some/path/where/to/retrieve/data".

def mockOnce(path: String, delay: Long): Unit

Scala API.

Scala API. Define successful once behavior for a given path.

path: a non empty String, formatted as "some/path/where/to/retrieve/data".
delay: a Long representing the delay in milliseconds before response should be sent.

def mockOnce(path: String, response: (String, String)): Unit

Scala API.

Scala API. Define once behavior for a given path, where given response is sent immediately.

path: a non empty String, formatted as "some/path/where/to/retrieve/data".
response: a (String, String) tuple that should be null to remove some existing once behavior, or should define the expected once process for this path. First element of this tuple represents successful response, second one the error message of a failing response.

def mockOnce(path: String, response: (String, String), delay: Long): Unit

Scala API.

Scala API. Define once behavior for a given path.

path: a non empty String, formatted as "some/path/where/to/retrieve/data".
response: a (String, String) tuple that should be null to remove some existing once behavior, or should define the expected once process for this path. First element of this tuple represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockOnceJ(): Unit

Java API.

Java API. Define successful once behavior for any path, where given response is sent immediately.

def mockOnceJ(delay: Long): Unit

Java API.

Java API. Define successful once behavior for any path.

delay: a Long representing the delay in milliseconds before response should be sent.

def mockOnceJ(response: Pair[String, String]): Unit

Java API.

Java API. Define once behavior for any path, where given response is sent immediately.

response: a Pair<String, String> that should be null to remove some existing once behavior, or should define the expected once process for this path. First element of this pair represents successful response, second one the error message of a failing response.

def mockOnceJ(response: Pair[String, String], delay: Long): Unit

Java API.

Java API. Define once behavior for any path.

response: a Pair<String, String> that should be null to remove some existing once behavior, or should define the expected once process for this path. First element of this pair represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockOnceJ(path: String): Unit

Java API.

Java API. Define successful once behavior for a given path, where given response is sent immediately.

path: a non empty String, formatted as "some/path/where/to/retrieve/data".

def mockOnceJ(path: String, delay: Long): Unit

Java API.

Java API. Define successful once behavior for a given path.

path: a non empty String, formatted as "some/path/where/to/retrieve/data".
delay: a Long representing the delay in milliseconds before response should be sent.

def mockOnceJ(path: String, response: Pair[String, String]): Unit

Java API.

Java API. Define once behavior for a given path, where given response is sent immediately.

path: a non empty String, formatted as "some/path/where/to/retrieve/data".
response: a Pair<String, String> that should be null to remove some existing once behavior, or should define the expected once process for this path. First element of this pair represents successful response, second one the error message of a failing response.

def mockOnceJ(path: String, response: Pair[String, String], delay: Long): Unit

Java API.

Java API. Define once behavior for a given path.

path: a non empty String, formatted as "some/path/where/to/retrieve/data".
response: a Pair<String, String> that should be null to remove some existing once behavior, or should define the expected once process for this path. First element of this pair represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockPush(): Unit

Scala API.

Scala API. Define successful PUSH behavior for any (path, JSON string) couple, where response is sent immediately.

def mockPush(delay: Long): Unit

Scala API.

Scala API. Define successful PUSH behavior for any (path, JSON string) couple.

delay: a Long representing the delay in milliseconds before response should be sent.

def mockPush(response: (String, String)): Unit

Scala API.

Scala API. Define PUSH behavior for any (path, JSON string) couple, where given response is sent immediately.

response: a (String, String) tuple that should be null to remove some existing PUSH behavior, or should define the expected PUSH process for this (path, JSON string) couple. First element of this tuple represents successful response, second one the error message of a failing response.

def mockPush(response: (String, String), delay: Long): Unit

Scala API.

Scala API. Define PUSH behavior for any (path, JSON string) couple.

response: a (String, String) tuple that should be null to remove some existing PUSH behavior, or should define the expected PUSH process for this (path, JSON string) couple. First element of this tuple represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockPush(path: String, json: String): Unit

Scala API.

Scala API. Define successful PUSH behavior for a given (path, JSON string) couple, where response is sent immediately.

path: a non empty String, formatted as "some/path/to/put/data".
json: a non empty JSON string representing the data to push.

def mockPush(path: String, json: String, delay: Long): Unit

Scala API.

Scala API. Define successful PUSH behavior for a given (path, JSON string) couple.

path: a non empty String, formatted as "some/path/to/put/data".
json: a non empty JSON string representing the data to push.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockPush(path: String, json: String, response: (String, String)): Unit

Scala API.

Scala API. Define PUSH behavior for a given (path, JSON string) couple, where given response is sent immediately.

path: a non empty String, formatted as "some/path/to/put/data".
json: a non empty JSON string representing the data to push.
response: a (String, String) tuple that should be null to remove some existing PUSH behavior, or should define the expected PUSH process for this (path, JSON string) couple. First element of this tuple represents successful response, second one the error message of a failing response.

def mockPush(path: String, json: String, response: (String, String), delay: Long): Unit

Scala API.

Scala API. Define PUSH behavior for a given (path, JSON string) couple.

path: a non empty String, formatted as "some/path/to/put/data".
json: a non empty JSON string representing the data to push.
response: a (String, String) tuple that should be null to remove some existing PUSH behavior, or should define the expected PUSH process for this (path, JSON string) couple. First element of this tuple represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockPushJ(): Unit

Java API.

Java API. Define successful PUSH behavior for any (path, JSON string) couple, where response is sent immediately.

def mockPushJ(delay: Long): Unit

Java API.

Java API. Define successful PUSH behavior for any (path, JSON string) couple.

delay: a Long representing the delay in milliseconds before response should be sent.

def mockPushJ(response: Pair[String, String]): Unit

Java API.

Java API. Define PUSH behavior for any (path, JSON string) couple, where given response is sent immediately.

response: a Pair<String, String> that should be null to remove some existing PUSH behavior, or should define the expected PUSH process for this (path, JSON string) couple. First element of this pair represents successful response, second one the error message of a failing response.

def mockPushJ(response: Pair[String, String], delay: Long): Unit

Java API.

Java API. Define PUSH behavior for any (path, JSON string) couple.

response: a Pair<String, String> that should be null to remove some existing PUSH behavior, or should define the expected PUSH process for this (path, JSON string) couple. First element of this pair represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockPushJ(path: String, json: String): Unit

Java API.

Java API. Define successful PUSH behavior for a given (path, JSON string) couple, where response is sent immediately.

path: a non empty String, formatted as "some/path/to/put/data".
json: a non empty JSON string representing the data to push.

def mockPushJ(path: String, json: String, delay: Long): Unit

Java API.

Java API. Define successful PUSH behavior for a given (path, JSON string) couple.

path: a non empty String, formatted as "some/path/to/put/data".
json: a non empty JSON string representing the data to push.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockPushJ(path: String, json: String, response: Pair[String, String]): Unit

Java API.

Java API. Define PUSH behavior for a given (path, JSON string) couple, where given response is sent immediately.

path: a non empty String, formatted as "some/path/to/put/data".
json: a non empty JSON string representing the data to push.
response: a Pair<String, String> that should be null to remove some existing PUSH behavior, or should define the expected PUSH process for this (path, JSON string) couple. First element of this pair represents successful response, second one the error message of a failing response.

def mockPushJ(path: String, json: String, response: Pair[String, String], delay: Long): Unit

Java API.

Java API. Define PUSH behavior for a given (path, JSON string) couple.

path: a non empty String, formatted as "some/path/to/put/data".
json: a non empty JSON string representing the data to push.
response: a Pair<String, String> that should be null to remove some existing PUSH behavior, or should define the expected PUSH process for this (path, JSON string) couple. First element of this pair represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockPut(): Unit

Scala API.

Scala API. Define successful PUT behavior for any (path, JSON string) couple, where response is sent immediately.

def mockPut(delay: Long): Unit

Scala API.

Scala API. Define successful PUT behavior for any (path, JSON string) couple.

delay: a Long representing the delay in milliseconds before response should be sent.

def mockPut(response: (AnyRef, String)): Unit

Scala API.

Scala API. Define PUT behavior for any (path, JSON string) couple, where given response is sent immediately.

response: a (AnyRef, String) tuple that should be null to remove some existing PUT behavior, or should define the expected PUT process for this (path, JSON string) couple. First element of this tuple represents successful response, second one the error message of a failing response.

def mockPut(response: (AnyRef, String), delay: Long): Unit

Scala API.

Scala API. Define PUT behavior for any (path, JSON string) couple.

response: a (AnyRef, String) tuple that should be null to remove some existing PUT behavior, or should define the expected PUT process for this (path, JSON string) couple. First element of this tuple represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockPut(path: String, json: String): Unit

Scala API.

Scala API. Define successful PUT behavior for a given (path, JSON string) couple, where response is sent immediately.

path: a non empty String, formatted as "some/path/to/put/data".
json: a non empty JSON string representing the data to put.

def mockPut(path: String, json: String, delay: Long): Unit

Scala API.

Scala API. Define successful PUT behavior for a given (path, JSON string) couple.

path: a non empty String, formatted as "some/path/to/put/data".
json: a non empty JSON string representing the data to put.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockPut(path: String, json: String, response: (AnyRef, String)): Unit

Scala API.

Scala API. Define PUT behavior for a given (path, JSON string) couple, where given response is sent immediately.

path: a non empty String, formatted as "some/path/to/put/data".
json: a non empty JSON string representing the data to put.
response: a (AnyRef, String) tuple that should be null to remove some existing PUT behavior, or should define the expected PUT process for this (path, JSON string) couple. First element of this tuple represents successful response, second one the error message of a failing response.

def mockPut(path: String, json: String, response: (AnyRef, String), delay: Long): Unit

Scala API.

Scala API. Define PUT behavior for a given (path, JSON string) couple.

path: a non empty String, formatted as "some/path/to/put/data".
json: a non empty JSON string representing the data to put.
response: a (AnyRef, String) tuple that should be null to remove some existing PUT behavior, or should define the expected PUT process for this (path, JSON string) couple. First element of this tuple represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockPutJ(): Unit

Java API.

Java API. Define successful PUT behavior for any (path, JSON string) couple, where response is sent immediately.

def mockPutJ(delay: Long): Unit

Java API.

Java API. Define successful PUT behavior for any (path, JSON string) couple.

delay: a Long representing the delay in milliseconds before response should be sent.

def mockPutJ(response: Pair[AnyRef, String]): Unit

Java API.

Java API. Define PUT behavior for any (path, JSON string) couple, where given response is sent immediately.

response: a Pair<Object, String> that should be null to remove some existing PUT behavior, or should define the expected PUT process for this (path, JSON string) couple. First element of this pair represents successful response, second one the error message of a failing response.

def mockPutJ(response: Pair[AnyRef, String], delay: Long): Unit

Java API.

Java API. Define PUT behavior for any (path, JSON string) couple.

response: a Pair<Object, String> that should be null to remove some existing PUT behavior, or should define the expected PUT process for this (path, JSON string) couple. First element of this pair represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockPutJ(path: String, json: String): Unit

Java API.

Java API. Define successful PUT behavior for a given (path, JSON string) couple, where response is sent immediately.

path: a non empty String, formatted as "some/path/to/put/data".
json: a non empty JSON string representing the data to put.

def mockPutJ(path: String, json: String, delay: Long): Unit

Java API.

Java API. Define successful PUT behavior for a given (path, JSON string) couple.

path: a non empty String, formatted as "some/path/to/put/data".
json: a non empty JSON string representing the data to put.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockPutJ(path: String, json: String, response: Pair[AnyRef, String]): Unit

Java API.

Java API. Define PUT behavior for a given (path, JSON string) couple, where given response is sent immediately.

path: a non empty String, formatted as "some/path/to/put/data".
json: a non empty JSON string representing the data to put.
response: a Pair<Object, String> that should be null to remove some existing PUT behavior, or should define the expected PUT process for this (path, JSON string) couple. First element of this pair represents successful response, second one the error message of a failing response.

def mockPutJ(path: String, json: String, response: Pair[AnyRef, String], delay: Long): Unit

Java API.

Java API. Define PUT behavior for a given (path, JSON string) couple.

path: a non empty String, formatted as "some/path/to/put/data".
json: a non empty JSON string representing the data to put.
response: a Pair<Object, String> that should be null to remove some existing PUT behavior, or should define the expected PUT process for this (path, JSON string) couple. First element of this pair represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockUnlisten(): Unit

Scala API.

Scala API. Define successful unlisten behavior for any path, where response is sent immediately.

def mockUnlisten(delay: Long): Unit

Scala API.

Scala API. Define successful unlisten behavior for any path.

delay: a Long representing the delay in milliseconds before response should be sent.

def mockUnlisten(response: (AnyRef, String)): Unit

Scala API.

Scala API. Define unlisten behavior for any path, where given response is sent immediately.

response: a (AnyRef, String) tuple that should be null to remove some existing unlisten behavior, or should define the expected unlisten process for this path. First element of this tuple represents successful response, second one the error message of a failing response.

def mockUnlisten(response: (AnyRef, String), delay: Long): Unit

Scala API.

Scala API. Define unlisten behavior for any path.

response: a (AnyRef, String) tuple that should be null to remove some existing unlisten behavior, or should define the expected unlisten process for this path. First element of this tuple represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockUnlisten(path: String): Unit

Scala API.

Scala API. Define successful unlisten behavior for a given path, where response is sent immediately.

path: a non empty String, formatted as "some/path/where/not/to/listen/anymore".

def mockUnlisten(path: String, delay: Long): Unit

Scala API.

Scala API. Define successful unlisten behavior for a given path.

path: a non empty String, formatted as "some/path/where/not/to/listen/anymore".
delay: a Long representing the delay in milliseconds before response should be sent.

def mockUnlisten(path: String, response: (AnyRef, String)): Unit

Scala API.

Scala API. Define unlisten behavior for a given path, where given response is sent immediately.

path: a non empty String, formatted as "some/path/where/not/to/listen/anymore".
response: a (AnyRef, String) tuple that should be null to remove some existing unlisten behavior, or should define the expected unlisten process for this path. First element of this tuple represents successful response, second one the error message of a failing response.

def mockUnlisten(path: String, response: (AnyRef, String), delay: Long): Unit

Scala API.

Scala API. Define unlisten behavior for a given path.

path: a non empty String, formatted as "some/path/where/not/to/listen/anymore".
response: a (AnyRef, String) tuple that should be null to remove some existing unlisten behavior, or should define the expected unlisten process for this path. First element of this tuple represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockUnlistenJ(): Unit

Java API.

Java API. Define successful unlisten behavior for any path, where response is sent immediately.

def mockUnlistenJ(delay: Long): Unit

Java API.

Java API. Define successful unlisten behavior for any path.

delay: a Long representing the delay in milliseconds before response should be sent.

def mockUnlistenJ(response: Pair[AnyRef, String]): Unit

Java API.

Java API. Define unlisten behavior for any path, where response is sent immediately.

response: a Pair<Object, String> that should be null to remove some existing unlisten behavior, or should define the expected unlisten process for this path. First element of this pair represents successful response, second one the error message of a failing response.

def mockUnlistenJ(response: Pair[AnyRef, String], delay: Long): Unit

Java API.

Java API. Define unlisten behavior for any path.

response: a Pair<Object, String> that should be null to remove some existing unlisten behavior, or should define the expected unlisten process for this path. First element of this pair represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

def mockUnlistenJ(path: String): Unit

Java API.

Java API. Define successful unlisten behavior for a given path, where response is sent immediately.

path: a non empty String, formatted as "some/path/where/not/to/listen/anymore".

def mockUnlistenJ(path: String, delay: Long): Unit

Java API.

Java API. Define successful unlisten behavior for a given path.

path: a non empty String, formatted as "some/path/where/not/to/listen/anymore".
delay: a Long representing the delay in milliseconds before response should be sent.

def mockUnlistenJ(path: String, response: Pair[AnyRef, String]): Unit

Java API.

Java API. Define unlisten behavior for a given path, where given response is sent immediately.

path: a non empty String, formatted as "some/path/where/not/to/listen/anymore".
response: a Pair<Object, String> that should be null to remove some existing unlisten behavior, or should define the expected unlisten process for this path. First element of this pair represents successful response, second one the error message of a failing response.

def mockUnlistenJ(path: String, response: Pair[AnyRef, String], delay: Long): Unit

Java API.

Java API. Define unlisten behavior for a given path.

path: a non empty String, formatted as "some/path/where/not/to/listen/anymore".
response: a Pair<Object, String> that should be null to remove some existing unlisten behavior, or should define the expected unlisten process for this path. First element of this pair represents successful response, second one the error message of a failing response.
delay: a Long representing the delay in milliseconds before response should be sent.

final def ne(arg0: AnyRef): Boolean

Definition Classes: AnyRef

final def notify(): Unit

Definition Classes: AnyRef
Annotations: @native()

final def notifyAll(): Unit

Definition Classes: AnyRef
Annotations: @native()

def once(path: String): Future[String]

Scala API.

Scala API. Mock the Datasync 'once' method. This method is called by any application under test instead of DatasyncClient.once method.

path: the path where to retrieve data, formatted as "some/path/where/to/retrieve/data".
returns: a Future[String] that may fail if operation fails.

Definition Classes: MockDatasyncClient → DatasyncClient

def onceJ(path: String): CompletionStage[String]

Java API.

Java API. Mock the Datasync 'onceJ' method. This method is called by any application under test * instead of DatasyncClient.onceJ method.

path: the path where to retrieve data, formatted as "some/path/where/to/retrieve/data".
returns: a CompletionStage<String> that may fail if operation fails.

Definition Classes: MockDatasyncClient → DatasyncClient

def push(path: String, json: String): Future[String]

Scala API.

Scala API. Mock the Datasync 'push' method. This method is called by any application under test instead of DatasyncClient.push method.

path: the path where to push data on that application, formatted as "some/path/to/push/data". If the path does not exist, it will be created in the application's tree. The path is suffixed with a randomly generated level (something like '-KwAf_EG49lohVcG7grO') before data is stored in it. This may be useful to store statistics, for instance.
json: a JSON string representing the data to push.
returns: a Future[String] containing the unique id added to the path.

Definition Classes: MockDatasyncClient → DatasyncClient

def pushJ(path: String, json: String): CompletionStage[String]

Java API.

Java API. Mock the Datasync 'pushJ' method. This method is called by any application under test instead of DatasyncClient.pushJ method.

path: the path where to push data on that application, formatted as "some/path/to/push/data". If the path does not exist, it will be created in the application's tree. The path is suffixed with a randomly generated level (something like '-KwAf_EG49lohVcG7grO') before data is stored in it. This may be useful to store statistics, for instance.
json: a JSON string representing the data to push.
returns: a CompletionStage<String> containing the unique id added to the path.

Definition Classes: MockDatasyncClient → DatasyncClient

def put(path: String, json: String): Future[Unit]

Scala API.

Scala API. Mock the Datasync 'put' method. This method is called by any application under test instead of DatasyncClient.put method.

path: the path where to put data on that application, formatted as "some/path/to/put/data". If the path does not exist, it will be created in the application's tree.
json: a JSON string representing the data to put. Notice that existing data, if any, is overwritten by the data to put.
returns: a Future[Unit] that may fail if operation fails.

Definition Classes: MockDatasyncClient → DatasyncClient

def putJ(path: String, json: String): CompletionStage[Unit]

Java API.

Java API. Mock the Datasync 'putJ' method. This method is called by any application under test instead of DatasyncClient.putJ method.

path: the path where to put data on that application, formatted as "some/path/to/put/data". If the path does not exist, it will be created in the application's tree.
json: a JSON string representing the data to put.
returns: a CompletionStage<BoxedUnit> that may fail if operation fails.

Definition Classes: MockDatasyncClient → DatasyncClient

final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes: AnyRef

def toString(): String

Definition Classes: AnyRef → Any

def unlisten(path: String): Future[Unit]

Scala API.

Scala API. Mock the Datasync 'unlisten' method. This method is called by any application under test instead of DatasyncClient.unlisten method.

path: the path where to stop listening to, formatted as "some/path/where/to/stop/listening".
returns: a Future[Unit] that may fail if operation fails.

Definition Classes: MockDatasyncClient → DatasyncClient

def unlistenJ(path: String): CompletionStage[Unit]

Java API.

Java API. Mock the Datasync 'unlistenJ' method. This method is called by any application under test instead of DatasyncClient.unlistenJ method.

path: the path where to stop listening to, formatted as "some/path/where/to/stop/listening".
returns: a CompletionStage<BoxedUnit> that may fail if operation fails.

Definition Classes: MockDatasyncClient → DatasyncClient

final def wait(): Unit

Definition Classes: AnyRef
Annotations: @throws( ... )

final def wait(arg0: Long, arg1: Int): Unit

Definition Classes: AnyRef
Annotations: @throws( ... )

final def wait(arg0: Long): Unit

Definition Classes: AnyRef
Annotations: @native() @throws( ... )

Packages

MockDatasyncClient

Companion object MockDatasyncClient

class MockDatasyncClient extends DatasyncClient with LazyLogging

Instance Constructors

Value Members

Inherited from LazyLogging

Inherited from DatasyncClient

Inherited from AnyRef

Inherited from Any

Ungrouped

Packages

MockDatasyncClient 

Companion object MockDatasyncClient

class MockDatasyncClient extends DatasyncClient with LazyLogging

Instance Constructors

Value Members

Inherited from LazyLogging

Inherited from DatasyncClient

Inherited from AnyRef

Inherited from Any

Ungrouped

MockDatasyncClient