^\
foo
🤦♂️
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<?xml version="1.0" encoding="UTF-8"?> | |
<rss xmlns:googleplay="http://www.google.com/schemas/play-podcasts/1.0" version="2.0"> | |
<channel> | |
<title>The Unknown Podcast</title> | |
<link>http://sample.com/podcasts/unknown/index.html</link> | |
<language>en-us</language> | |
<copyright>℗ 2025 Unknown Podcaster Corp</copyright> | |
<googleplay:author>Unannounced Podcaster</googleplay:author> | |
<googleplay:description>The Unknown Podcast will look at all the things that are unknown or unknowable. Find us on Google Play Music!</googleplay:description> | |
<description>The Unknown Podcast will look at all the things that are unknown or unknowable.</description> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
view-request::submit request: | |
mean: 5.3µs, p50: 8µs, p90: 16µs, p99: 24µs, p999: 24µs, max: 24µs, #: 34 | |
1µs | ************************************ | 88.2th %-ile | |
2µs | | 88.2th %-ile | |
4µs | | 88.2th %-ile | |
8µs | | 88.2th %-ile | |
16µs | **** | 97.1th %-ile | |
view-request::waiting for service readiness: | |
mean: 1404.2µs, p50: 1466µs, p90: 1859µs, p99: 3670µs, p999: 3670µs, max: 3670µs, #: 34 | |
64µs | ** | 2.9th %-ile |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
diff --git a/tower-buffer/Cargo.toml b/tower-buffer/Cargo.toml | |
index 328a0c7..4728c9e 100644 | |
--- a/tower-buffer/Cargo.toml | |
+++ b/tower-buffer/Cargo.toml | |
@@ -21,12 +21,17 @@ Buffer requests before dispatching to a `Service`. | |
categories = ["asynchronous", "network-programming"] | |
edition = "2018" | |
+[features] | |
+log = ["tracing/log"] |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| cargo t | |
Compiling hdrhistogram v6.1.1 | |
Compiling crossbeam-deque v0.7.1 | |
Compiling rand v0.6.5 | |
Compiling parking_lot v0.6.4 | |
Compiling hdrsample v6.0.3 | |
Compiling tower-spawn-ready v0.1.0 (/home/jon/dev/others/tower/tower-spawn-ready) | |
Compiling tower-limit v0.1.0 | |
Compiling tower-load v0.1.0 (/home/jon/dev/others/tower/tower-load) | |
error[E0277]: the trait bound `tokio_sync::oneshot::error::RecvError: std::error::Error` is not satisfied |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
struct OneShotTimer { | |
fd: Box<std::os::unix::io::RawFd>, | |
e: Option<tokio_reactor::PollEvented<mio::unix::EventedFd<'static>>>, | |
} | |
impl OneShotTimer { | |
fn new(d: time::Duration) -> io::Result<Self> { | |
if d.as_secs() == 0 && d.subsec_nanos() == 0 { | |
// this would be interpreted as "inactive timer" by timerfd_settime | |
return Ok(OneShotTimer { |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#!/usr/bin/env run-cargo-script | |
//! ```cargo | |
//! [dependencies] | |
//! tokio = "0.1" | |
//! hyper = "0.12" | |
//! futures = "0.1" | |
//! tower-service = { git = "https://github.com/tower-rs/tower.git" } | |
//! tower-buffer = { git = "https://github.com/tower-rs/tower.git" } | |
//! ``` | |
extern crate futures; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
extern crate async_bincode; | |
#[macro_use] | |
extern crate futures; | |
extern crate serde; | |
#[macro_use] | |
extern crate serde_derive; | |
extern crate bincode; | |
extern crate tokio; | |
extern crate tower_service; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
.message-group .comment .markup, .chat { | |
color: inherit; | |
} | |
.message-group.compact .message .timestamp { | |
color: #555; | |
float: right; | |
} | |
.reaction .reaction-count { | |
color: inherit; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#0 0x00007fafb46f7ffc in pthread_cond_wait@@GLIBC_2.3.2 () from /usr/lib/libpthread.so.0 | |
#1 0x000055e6e56d7d3c in std::sys::unix::condvar::Condvar::wait (self=0x7faf9ae51130, mutex=0x7faf9ae51100) | |
at /checkout/src/libstd/sys/unix/condvar.rs:78 | |
#2 0x000055e6e56d7ce6 in std::sys_common::condvar::Condvar::wait (self=0x7faf9ae51130, mutex=0x7faf9ae51100) | |
at /checkout/src/libstd/sys_common/condvar.rs:51 | |
#3 0x000055e6e56d458a in std::sync::condvar::Condvar::wait (self=0x7faf9afaade8, guard=...) | |
at /checkout/src/libstd/sync/condvar.rs:214 | |
#4 0x000055e6e56d0047 in futures::task_impl::std::ThreadNotify::park (self=0x7faf9afaadd0) | |
at /home/jon/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.21/src/task_impl/std/mod.rs:536 | |
#5 0x000055e6e55f30f6 in futures::task_impl::std::<impl futures::task_impl::Spawn<F>>::wait_future::{{closure}} ( |