From 4a46c1031aa69e7ba0e309ba9692250f14dba6b8 Mon Sep 17 00:00:00 2001
From: dakkar <dakkar@thenautilus.net>
Date: Sat, 9 Dec 2023 14:02:41 +0000
Subject: actually async

---
 lib/WebService/TFL/Bus.pm | 20 ++++++++------------
 1 file changed, 8 insertions(+), 12 deletions(-)

(limited to 'lib/WebService/TFL/Bus.pm')

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;
 
-- 
cgit v1.2.3