mirror of
https://github.com/actix/actix-extras.git
synced 2025-08-18 14:45:32 +02:00
Deploying to gh-pages from @ 61778d864e
🚀
This commit is contained in:
@@ -14,7 +14,7 @@
|
||||
</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#113-129' 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#114-128' 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.7/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 allows to handle <code>Stream</code> in similar way as normal actor messages. <a href="#method.add_stream">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 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#97-104' 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#98-103' 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#106-111' 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#107-110' 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>
|
||||
</div><h4 id='method.finished-1' 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>Called when the writer finishes. <a href="#method.finished">Read more</a></p>
|
||||
|
Reference in New Issue
Block a user