Package akka.agent
Class Agent<T>
- java.lang.Object
-
- akka.agent.Agent<T>
-
public abstract class Agent<T> extends java.lang.Object
Deprecated.Agents are deprecated and scheduled for removal in the next major version, use Actors instead. Since 2.5.0.Java API: Read the internal state of the agent.
-
-
Constructor Summary
Constructors Constructor Description Agent()
Deprecated.
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Deprecated Methods Modifier and Type Method Description abstract scala.concurrent.Future<T>
alter(scala.Function1<T,T> f)
Deprecated.Dispatch a function to update the internal state, and return a Future where that new state can be obtained.abstract scala.concurrent.Future<T>
alter(T newValue)
Deprecated.Dispatch an update to the internal state, and return a Future where that new state can be obtained.abstract scala.concurrent.Future<T>
alterOff(scala.Function1<T,T> f, scala.concurrent.ExecutionContext ec)
Deprecated.Dispatch a function to update the internal state but on its own thread, and return a Future where that new state can be obtained.T
apply()
Deprecated.Read the internal state of the agent.static <T> Agent<T>
create(T initialValue, scala.concurrent.ExecutionContext context)
Deprecated.Agents are deprecated and scheduled for removal in the next major version, use Actors instead.iabstract <B> Agent<B>
flatMap(scala.Function1<T,Agent<B>> f)
Deprecated.Flatmap this agent to a new agent, applying the function to the internal state.abstract <U> void
foreach(scala.Function1<T,U> f)
Deprecated.Applies the function to the internal state.abstract scala.concurrent.Future<T>
future()
Deprecated.A future to the current value that will be completed after any currently queued updates.abstract T
get()
Deprecated.abstract <B> Agent<B>
map(scala.Function1<T,B> f)
Deprecated.Map this agent to a new agent, applying the function to the internal state.abstract void
send(scala.Function1<T,T> f)
Deprecated.Dispatch a function to update the internal state.abstract void
send(T newValue)
Deprecated.Dispatch a new value for the internal state.abstract void
sendOff(scala.Function1<T,T> f, scala.concurrent.ExecutionContext ec)
Deprecated.Dispatch a function to update the internal state but on its own thread.
-
-
-
Method Detail
-
create
public static <T> Agent<T> create(T initialValue, scala.concurrent.ExecutionContext context)
Deprecated.Agents are deprecated and scheduled for removal in the next major version, use Actors instead.iJava API: Factory method for creating an Agent.- Parameters:
initialValue
- (undocumented)context
- (undocumented)- Returns:
- (undocumented)
-
get
public abstract T get()
Deprecated.
-
apply
public T apply()
Deprecated.Read the internal state of the agent.- Returns:
- (undocumented)
-
send
public abstract void send(T newValue)
Deprecated.Dispatch a new value for the internal state. Behaves the same as sending a function (x => newValue).- Parameters:
newValue
- (undocumented)
-
send
public abstract void send(scala.Function1<T,T> f)
Deprecated.Dispatch a function to update the internal state. In Java, pass in an instance ofakka.dispatch.Mapper
.- Parameters:
f
- (undocumented)
-
sendOff
public abstract void sendOff(scala.Function1<T,T> f, scala.concurrent.ExecutionContext ec)
Deprecated.Dispatch a function to update the internal state but on its own thread. This does not use the reactive thread pool and can be used for long-running or blocking operations. Dispatches using eithersendOff
orsend
will still be executed in order. In Java, pass in an instance ofakka.dispatch.Mapper
.- Parameters:
f
- (undocumented)ec
- (undocumented)
-
alter
public abstract scala.concurrent.Future<T> alter(T newValue)
Deprecated.Dispatch an update to the internal state, and return a Future where that new state can be obtained. In Java, pass in an instance ofakka.dispatch.Mapper
.- Parameters:
newValue
- (undocumented)- Returns:
- (undocumented)
-
alter
public abstract scala.concurrent.Future<T> alter(scala.Function1<T,T> f)
Deprecated.Dispatch a function to update the internal state, and return a Future where that new state can be obtained. In Java, pass in an instance ofakka.dispatch.Mapper
.- Parameters:
f
- (undocumented)- Returns:
- (undocumented)
-
alterOff
public abstract scala.concurrent.Future<T> alterOff(scala.Function1<T,T> f, scala.concurrent.ExecutionContext ec)
Deprecated.Dispatch a function to update the internal state but on its own thread, and return a Future where that new state can be obtained. This does not use the reactive thread pool and can be used for long-running or blocking operations. Dispatches using eitheralterOff
oralter
will still be executed in order. In Java, pass in an instance ofakka.dispatch.Mapper
.- Parameters:
f
- (undocumented)ec
- (undocumented)- Returns:
- (undocumented)
-
future
public abstract scala.concurrent.Future<T> future()
Deprecated.A future to the current value that will be completed after any currently queued updates.- Returns:
- (undocumented)
-
map
public abstract <B> Agent<B> map(scala.Function1<T,B> f)
Deprecated.Map this agent to a new agent, applying the function to the internal state. Does not change the value of this agent. In Java, pass in an instance ofakka.dispatch.Mapper
.- Parameters:
f
- (undocumented)- Returns:
- (undocumented)
-
flatMap
public abstract <B> Agent<B> flatMap(scala.Function1<T,Agent<B>> f)
Deprecated.Flatmap this agent to a new agent, applying the function to the internal state. Does not change the value of this agent. In Java, pass in an instance ofakka.dispatch.Mapper
.- Parameters:
f
- (undocumented)- Returns:
- (undocumented)
-
foreach
public abstract <U> void foreach(scala.Function1<T,U> f)
Deprecated.Applies the function to the internal state. Does not change the value of this agent. In Java, pass in an instance ofakka.dispatch.Foreach
.- Parameters:
f
- (undocumented)
-
-