mirror of
https://github.com/actix/actix-extras.git
synced 2025-08-31 03:20:20 +02:00
Deploying to gh-pages from @ 81c48930c4
🚀
This commit is contained in:
@@ -17,7 +17,7 @@ address. <a href="#method.start_default">Read more</a></p>
|
||||
</div></div><h3 id="impl-StreamHandler%3CResult%3CRespValue%2C%20Error%3E%3E" class="impl"><code class="in-band">impl StreamHandler<<a class="enum" href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html" title="enum core::result::Result">Result</a><<a class="enum" href="../actix_redis/enum.RespValue.html" title="enum actix_redis::RespValue">RespValue</a>, <a class="enum" href="../actix_redis/enum.RespError.html" title="enum actix_redis::RespError">Error</a>>> for <a class="struct" href="../actix_redis/struct.RedisActor.html" title="struct actix_redis::RedisActor">RedisActor</a></code><a href="#impl-StreamHandler%3CResult%3CRespValue%2C%20Error%3E%3E" class="anchor"></a><a class="srclink" href="../src/actix_redis/redis.rs.html#115-131" title="goto source code">[src]</a></h3><div class="impl-items"><h4 id="method.handle-1" class="method hidden"><code>fn <a href="#method.handle" class="fnname">handle</a>(&mut self, msg: <a class="enum" href="https://doc.rust-lang.org/nightly/core/result/enum.Result.html" title="enum core::result::Result">Result</a><<a class="enum" href="../actix_redis/enum.RespValue.html" title="enum actix_redis::RespValue">RespValue</a>, <a class="enum" href="../actix_redis/enum.RespError.html" title="enum actix_redis::RespError">RespError</a>>, ctx: &mut Self::Context)</code><a class="srclink" href="../src/actix_redis/redis.rs.html#116-130" title="goto source code">[src]</a></h4><div class='docblock hidden'><p>Method is called for every message received by this Actor</p>
|
||||
</div><h4 id="method.started-1" class="method hidden"><code>fn <a href="#method.started" class="fnname">started</a>(&mut self, ctx: &mut Self::Context)</code></h4><div class='docblock hidden'><p>Method is called when stream get polled first time.</p>
|
||||
</div><h4 id="method.finished" class="method hidden"><code>fn <a href="#method.finished" class="fnname">finished</a>(&mut self, ctx: &mut Self::Context)</code></h4><div class='docblock hidden'><p>Method is called when stream finishes. <a href="#method.finished">Read more</a></p>
|
||||
</div><h4 id="method.add_stream" class="method hidden"><code>fn <a href="#method.add_stream" class="fnname">add_stream</a><S>(fut: S, ctx: &mut Self::Context) -> SpawnHandle <span class="where fmt-newline">where<br> I: 'static,<br> S: <a class="trait" href="https://docs.rs/futures-core/0.3.8/futures_core/stream/trait.Stream.html" title="trait futures_core::stream::Stream">Stream</a><Item = I> + 'static,<br> Self::Context: AsyncContext<Self>, </span></code></h4><div class='docblock hidden'><p>This method register stream to an actor context and
|
||||
</div><h4 id="method.add_stream" class="method hidden"><code>fn <a href="#method.add_stream" class="fnname">add_stream</a><S>(fut: S, ctx: &mut Self::Context) -> SpawnHandle <span class="where fmt-newline">where<br> I: 'static,<br> S: Stream<Item = I> + 'static,<br> Self::Context: AsyncContext<Self>, </span></code></h4><div class='docblock hidden'><p>This method register stream to an actor context and
|
||||
allows to handle <code>Stream</code> in similar way as normal actor messages. <a href="#method.add_stream">Read more</a></p>
|
||||
</div></div><h3 id="impl-Supervised" class="impl"><code class="in-band">impl Supervised for <a class="struct" href="../actix_redis/struct.RedisActor.html" title="struct actix_redis::RedisActor">RedisActor</a></code><a href="#impl-Supervised" class="anchor"></a><a class="srclink" href="../src/actix_redis/redis.rs.html#99-106" title="goto source code">[src]</a></h3><div class="impl-items"><h4 id="method.restarting" class="method hidden"><code>fn <a href="#method.restarting" class="fnname">restarting</a>(&mut self, _: &mut Self::Context)</code><a class="srclink" href="../src/actix_redis/redis.rs.html#100-105" title="goto source code">[src]</a></h4><div class='docblock hidden'><p>Called when the supervisor restarts a failed actor.</p>
|
||||
</div></div><h3 id="impl-WriteHandler%3CError%3E" class="impl"><code class="in-band">impl WriteHandler<<a class="struct" href="https://doc.rust-lang.org/nightly/std/io/error/struct.Error.html" title="struct std::io::error::Error">Error</a>> for <a class="struct" href="../actix_redis/struct.RedisActor.html" title="struct actix_redis::RedisActor">RedisActor</a></code><a href="#impl-WriteHandler%3CError%3E" class="anchor"></a><a class="srclink" href="../src/actix_redis/redis.rs.html#108-113" title="goto source code">[src]</a></h3><div class="impl-items"><h4 id="method.error" class="method hidden"><code>fn <a href="#method.error" class="fnname">error</a>(&mut self, err: <a class="struct" href="https://doc.rust-lang.org/nightly/std/io/error/struct.Error.html" title="struct std::io::error::Error">Error</a>, _: &mut Self::Context) -> Running</code><a class="srclink" href="../src/actix_redis/redis.rs.html#109-112" title="goto source code">[src]</a></h4><div class='docblock hidden'><p>Called when the writer emits error. <a href="#method.error">Read more</a></p>
|
||||
|
Reference in New Issue
Block a user