mongodb - Elixir streaming mondodb fail -


I am using nectar-mongo and am trying to stream the result of a query. Here is the code ... 

  def archive_stream (z) are Stream.resource (fn - & gt; {employment, date} = z l = datetime_to_bson_utc datetime c = jobs | & gt; Mongo.Collection .find (% {updated_at:% { "$ lt": lt}}) | & gt; Mongokfind. Aksisi {: cont, c.response.buffer, c} end, fn (z) - & {J, {cont, therest, c}} = front (z) case cont: cont -> {j, {cont, therest, c}}: halt - & gt; {: halt, {cont, Therest, c}} end end, fn (: halt, resp - - gt; resp end)

end

all sub-bits start working ( Like queries), but when I try to access the stream, I fail ... 

  Mdb.archive_stre Am ({jobs, {{2013,11,1}, {0}}}}) | & Gt; Enum.take (2)

I ...

(BadArityError) # of the function & lt; 2.4 9 475 9 06 1/2 argument with Mdb.archive_stream / 1> Iriyti 2 ({: cont, & lt; 9, 44, 0, 0, 7, 95, 105, 100, 0, 82, 110, 12 9 , 221, 102, 160, 249, 201, 109, 0, 137, 233, 4, 95, 115, 108, 117, 103, 115, 0, 51, 0, 0, 0, 2, 48, 0, 39, 0, 0, 0, 109, 97, 110, 97, 103, 101, 114, 45, ... >>,% Mongo .ursor {batchSize: 0, Archive:% Mongo.Collection {db:% Mongo .Db {Certification: { "admin", "Edd5404c4f906060bl25688e26ffb28l"}, Mongo:% MongokServer {host: 'db-stage.member0.mongolayer .com', id_prefix: 57,602, modes: passive, opt:% { }, Port: 27017, socket: # port & lt; 0.270 99>, timeout: 6000}, name: "db phase", opto:% {mode: idle, timeout: 6000}}, name: "H Bs ", ops:% {}}, tired: wrong, feedback:% Mongo.Response {buffer: 18, 14, 0, 0, 7, 95, 105, 100, 0, 82, 110, 12 9, 221, 102, 160, 249, 201, 109, 0, 137, 242, 4, 95, 115, 108, 117, 103, 115, 0, 45, 0, 0, 2, 48, 0 , 33, 0, 0, 0, 114, 101, 116, 97, ... >>, cursorID: 3958284337526732701, decoder: & amp; Mongo.Response.bson_decode / 1, nbdoc: 101, requestID: 67,280,413, startingFrom: 0}}}) (nectar) lib / stream.ex: 1020: Stream.do_resource / 5 (nectar) lib / enum.ex: 1731: Enum.take / 2

stumped me has been done. any idea? Thanks for the help

Dang! Rookie error

: halt - & gt; {: Stop, {cont, therest, c}} should be _ -> {: Halt, z} and fn (: halt, resp) - & gt; Resp end should be fn (resp) -> Resp end

I am walking with everything but after working for one and a half days.

A little more clarification for fellow rookies

  • The last option in next_fun () might possibly be to catch "code" to other "bad behavior" Not only {: halt}
  • after_fn () is expected only 1 ARG and in the above code which will be z in the last option of next_fun (). It is not expecting to see : halt and z , simply z .

Investing of real experts.


Comments

Post a Comment

Popular posts from this blog

python - Overriding the save method in Django ModelForm -

I'm having trouble overriding a ModelForm save method. I get this error I'm: Exception type: TypeErier Exception Value: Save () found an unexpected keyword argument 'committed' My intentions include a form 3 fields Submit several values ​​for, then create an object for each combination of those areas, and to save each object file models.py class collarsult type (models.Model): id = model. AutoField (db_column = 'icontact_result_code_type_id', primary_key = true) callResult = models.ForeignKey ( 'CallResult', db_column = 'icontact_result_code_id') campaign = models.ForeignKey ( 'campaign', db_column = 'icampaign_id') CALLTYPE = models.ForeignKey ( 'CALLTYPE', db_column = 'icall_type_id') agent = models.BooleanField (db_column = 'bagent', default = true) teamLeader = models.BooleanField (db_column = 'bTeamLeader', default = true) active = models.BooleanField (db_column = Django.form...
Read more

html - CSS autoheight, but fit content to height of div -

I have a div in which there are three children- div in the left and middle div: float: left while true: float: true because it is my layout Actually will spoil, I've used ClearFix Hack: .cf {zoom: 1; }. Cf: First,. Cf: {content: ""; Display: Table; }. Cf: After {clear: both; } It still works, but I want to be the right div an indicator. So it should fill 100% of the parent unit of height. How can I complete this? PS is the full code: & Lt; / Div & gt; & Lt; Div class = "mobile_content" & gt; & Lt; H5 & gt; {{Data.titel}} & lt; / H5> & Lt; Table & gt; & Lt; TR & gt; & Lt; Th & gt; Komponist: & lt; / Th & gt; & Lt; TD & gt; {{Data.komponist}} & lt; / TD & gt; & Lt; / TR & gt; & Lt; TR & gt; & Lt; Th & gt; Instrument: & lt; / Th & gt; & Lt; TD & gt; {{Data.instrumente}} & lt; / TD & gt; & Lt; / TR & gt;...
Read more

qt - How to prevent QAudioInput from automatically boosting the master volume to 100%? -

I have been trying to use Qt5 multimedia to record audio with QAudioInput, however, when I see If QAudioInput is started, it increases the master volume of my sound device to 100%. How can I prevent QAudioInput from changing the master volume? My current development platform is Linux with PalsAdio (with flat audio disabled). How can I use QAudioInput : QAudioDeviceInfo device_info = QAudioDeviceInfo :: defaultInputDevice (); QAudio format format; Format.setSampleRate (44100); Format.setChannelCount (1); Format.setSampleSize (16); Format.setCodec ("Audio / PCM"); Format.setSampleType (QAudioFormat :: SignedInt); Format.setByteOrder (QAudioFormat :: LittleEndian); Std :: cout & lt; & Lt; Device_info.deviceName (). ToUtf8 (). ConstData () & lt; & Lt; Std :: endl; QAudioInput * default_device = new QAudioInput (device_info, format); QIODevice * default_io_device = default_device-> Start (); a QAudioInput.setVolume () method is not you I ...
Read more