summaryrefslogtreecommitdiff
path: root/lib/WebService/TFL/Bus.pm
diff options
context:
space:
mode:
Diffstat (limited to 'lib/WebService/TFL/Bus.pm')
-rw-r--r--lib/WebService/TFL/Bus.pm20
1 files changed, 8 insertions, 12 deletions
diff --git a/lib/WebService/TFL/Bus.pm b/lib/WebService/TFL/Bus.pm
index 31bd9c3..8f43c0f 100644
--- a/lib/WebService/TFL/Bus.pm
+++ b/lib/WebService/TFL/Bus.pm
@@ -1,21 +1,16 @@
package WebService::TFL::Bus;
use Moo;
use Types::URI 'Uri';
-use Type::Utils 'duck_type';
+use Types::Standard -types;
+use Future::AsyncAwait;
use WebService::TFL::Bus::Response;
use namespace::clean;
has user_agent => (
- isa => duck_type(['get']),
- is => 'lazy',
-
+ isa => HasMethods['do_request'],
+ is => 'ro',
+ required => 1,
);
-sub _build_user_agent {
- require LWP::UserAgent;
- my $ua = LWP::UserAgent->new();
- $ua->env_proxy;
- return $ua;
-}
has uri => (
isa => Uri,
@@ -29,7 +24,7 @@ has parser => (
builder => sub { JSON->new->utf8 },
);
-sub request {
+async sub request {
my ($self,$stop_id) = @_;
my $uri = $self->uri->clone;
@@ -37,7 +32,8 @@ sub request {
map { $_ eq '__' ? $stop_id : $_ } $uri->path_segments
);
- my $http_response = $self->user_agent->get($uri);
+ my $http_response = await $self->user_agent->do_request(uri => $uri);
+
if ($http_response->is_success) {
my $json = $http_response->content;