aboutsummaryrefslogtreecommitdiff
path: root/internal/imap/imap.go
diff options
context:
space:
mode:
authorRené 'Necoro' Neumann <necoro@necoro.eu>2021-02-28 13:22:17 +0100
committerRené 'Necoro' Neumann <necoro@necoro.eu>2021-02-28 13:22:17 +0100
commit4f112c16dfac61deb128b48e9d516f78ab55fc95 (patch)
treec9cb69966987ec59fc2eaf20b4fa377056e1f8f8 /internal/imap/imap.go
parentc407994dd3aeb2c5a8e5f3fa070e7436fe308fc9 (diff)
downloadfeed2imap-go-4f112c16dfac61deb128b48e9d516f78ab55fc95.tar.gz
feed2imap-go-4f112c16dfac61deb128b48e9d516f78ab55fc95.tar.bz2
feed2imap-go-4f112c16dfac61deb128b48e9d516f78ab55fc95.zip
Start IMAP connections in the background and use them on the go
Diffstat (limited to '')
-rw-r--r--internal/imap/imap.go12
1 files changed, 7 insertions, 5 deletions
diff --git a/internal/imap/imap.go b/internal/imap/imap.go
index 369d4b4..20713a4 100644
--- a/internal/imap/imap.go
+++ b/internal/imap/imap.go
@@ -48,6 +48,7 @@ func (cl *Client) connect(url config.Url) (*connection, error) {
return nil, fmt.Errorf("login to %s: %w", url.Host, err)
}
+ cl.connChannel <- conn
return conn, nil
}
@@ -61,6 +62,7 @@ func Connect(url config.Url) (*Client, error) {
client.Disconnect()
}
}()
+ client.startCommander()
var conn *connection // the main connection
if conn, err = client.connect(url); err != nil {
@@ -87,12 +89,12 @@ func Connect(url config.Url) (*Client, error) {
// the other connections
for i := 1; i < len(client.connections); i++ {
- if _, err := client.connect(url); err != nil { // explicitly new var 'err', b/c these are now harmless
- log.Warnf("connecting #%d: %s", i, err)
- }
+ go func(id int) {
+ if _, err := client.connect(url); err != nil { // explicitly new var 'err', b/c these are now harmless
+ log.Warnf("connecting #%d: %s", id, err)
+ }
+ }(i)
}
- client.startCommander()
-
return client, nil
}