Skip to content

Commit acbddff

Browse files
committed
fix stream api: don't use the process dictionary here
1 parent 8ea005a commit acbddff

File tree

2 files changed

+1
-3
lines changed

2 files changed

+1
-3
lines changed

lib/mongo/stream.ex

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,6 @@ defmodule Mongo.Stream do
3838
case Mongo.get_session(opts) do
3939
nil ->
4040
with {:ok, session} <- Session.start_session(topology_pid, :read, opts) do
41-
Process.put(:session, session)
4241
{:own, session}
4342
end
4443

@@ -49,7 +48,6 @@ defmodule Mongo.Stream do
4948

5049
def checkin_session(:own, session, topology_pid) do
5150
Session.end_session(topology_pid, session)
52-
Process.delete(:session)
5351
end
5452

5553
def checkin_session(:borrowed, _session, _topology_pid) do

mix.exs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ defmodule Mongodb.Mixfile do
22
use Mix.Project
33

44
@source_url "https://github.com/zookzook/elixir-mongodb-driver"
5-
@version "0.9.0-rc.0"
5+
@version "0.9.0-rc.1"
66

77
def project() do
88
[

0 commit comments

Comments
 (0)