@@ -151,16 +151,17 @@ defmodule Electric.ShapeCache.ShapeStatus.ShapeDb.Connection do
151151 end
152152
153153 defp init_worker_for_pool ( pool_state ) do
154- if ( Keyword . get ( pool_state , :exclusive_mode , false ) ) do
154+ if Keyword . get ( pool_state , :exclusive_mode , false ) do
155155 init_worker_exclusive ( pool_state )
156156 else
157157 init_worker_pooled ( pool_state )
158158 end
159159 end
160160
161161 defp init_worker_pooled ( pool_state ) do
162- with mode = Keyword . get ( pool_state , :mode , :readwrite ) ,
163- { :ok , conn } <- open ( pool_state ) ,
162+ mode = Keyword . get ( pool_state , :mode , :readwrite )
163+
164+ with { :ok , conn } <- open ( pool_state ) ,
164165 stmts <- Query . prepare! ( conn , mode ) do
165166 { :ok , % __MODULE__ { conn: conn , mode: mode , stmts: stmts } }
166167 end
@@ -172,8 +173,9 @@ defmodule Electric.ShapeCache.ShapeStatus.ShapeDb.Connection do
172173 # over the same, single, connection since every connection is a separate db
173174 # in in-memory mode.
174175 defp init_worker_exclusive ( pool_state ) do
175- with mode = :readwrite ,
176- { :ok , conn } <- open ( pool_state , integrity_check: true ) ,
176+ mode = :readwrite
177+
178+ with { :ok , conn } <- open ( pool_state , integrity_check: true ) ,
177179 { :ok , _version } <- migrate ( conn , pool_state ) ,
178180 stmts <- Query . prepare! ( conn , mode ) do
179181 { :ok , % __MODULE__ { conn: conn , mode: mode , stmts: stmts } }
0 commit comments