Rx เฉลี่ยเคลื่อนที่

ในโดเมนการเงินเรามักจะต้องคำนวณค่ารวมของการเคลื่อนที่ของหน้าต่างจากข้อมูลชุดข้อมูลเวลาโดยใช้ค่าเฉลี่ยเคลื่อนที่เป็นตัวอย่างให้เรามีข้อมูลต่อไปนี้ T คือการประทับเวลาและ V เป็นค่าจริงในการคำนวณ ค่าเฉลี่ยเคลื่อนที่ 3 จากสตรีมที่เราได้รับในการคำนวณค่าเฉลี่ยเคลื่อนที่เราจะทำเช่นนั้นโดย by. build สังเกตจาก stream. build เดิมสังเกตจากสตรีมเดิมโดยรวมค่าลงในกลุ่มผู้ให้บริการรวม เพื่อคำนวณผลสุดท้ายจาก Observable ในขั้นตอนที่ 2 ขั้นตอนที่ 1 และ 3 เป็นเรื่องเล็กน้อยที่จะใช้ แต่สำหรับขั้นตอนที่ 2 ดูเหมือนว่าปัจจุบัน RxJava ไม่มีผู้ดำเนินการ build-in เพื่อสร้างกลุ่ม windows-moving กลุ่ม window operator ของ Window ดูเหมือนจะไม่ พอดีในกรณีนี้และฉันไม่ได้หาวิธีที่ง่ายในการเขียนแก้ปัญหาจากผู้ประกอบการที่มีอยู่คนใดคนหนึ่งสามารถแนะนำวิธีการทำเช่นนี้ใน RxJava อย่างหรูหรา fashion. asked 28 ธันวาคม 13 ที่ 6 29.I d ทำเช่นนี้ ฉันใช้หน้าต่างที่ปล่อยสิ่งสังเกตซึ่ง onl y ใช้ปริมาณคงที่ของหน่วยความจำและไม่ใช่บัฟเฟอร์ที่ปล่อยรายการซึ่งใช้หน่วยความจำสำหรับแต่ละรายการของพวกเขานี่คือตัวอย่างของวิธีที่คุณสามารถใช้ตัวดำเนินการแบบ combinator แทนการเขียนลูปของคุณเองสิ่งที่คุณควรคำนึงถึงเสมอเมื่อใช้ Observables. Update ถ้าคุณต้องการกรองหน้าต่างในตอนท้ายของสตรีมที่มีองค์ประกอบน้อยกว่า n คุณสามารถทำเช่นนี้ได้ ฉันเลือกสกาล่าเพราะสั้นกว่าที่จะเขียน แต่ใน Java คุณสามารถทำเช่นเดียวกันเพียงทราบว่า Scala s foldLeft เรียกว่าลด Java. ตอบ 4 ม. ค. 14 ที่ 22 20.Practical Rx Training London 6-7 ตุลาคม 2015 นำเสนอโดยผู้เขียนของ PART 1 - เริ่มต้นผู้ใช้คาดหวังข้อมูลเวลาจริงพวกเขาต้องการทวีตของพวกเขาตอนนี้คำสั่งของพวกเขาได้รับการยืนยันตอนนี้พวกเขาต้องการราคาที่ถูกต้อง ณ ขณะนี้เกมออนไลน์ของพวกเขาจะต้องมีการตอบสนองในฐานะนักพัฒนาคุณต้องการ fire - and - ลืมข้อความคุณ don t ต้องการปิดกั้นรอผลคุณต้องการให้มีผลผลักดันให้คุณเมื่อพร้อมดียิ่งขึ้นเมื่อทำงานกับชุดผลลัพธ์คุณต้องการได้รับผลการค้นหาแต่ละรายการตามที่ต้องการคุณไม่ต้องการ รอให้ทั้งชุดที่จะประมวลผลก่อนที่คุณจะเห็นแถวแรกโลกได้ย้ายไปผลักดันผู้ใช้กำลังรอให้เราจับขึ้นนักพัฒนามีเครื่องมือในการผลักดันข้อมูลนี้เป็นเรื่องง่ายนักพัฒนาต้องใช้เครื่องมือในการตอบสนองต่อการผลักดันข้อมูลยินดีต้อนรับสู่ Reactive ส่วนขยายสำหรับ Rx หนังสือเล่มนี้มีวัตถุประสงค์เพื่อพัฒนาใด ๆ r อยากรู้เกี่ยวกับ IObservable T และ IObserver T interfaces ที่มีการผุดขึ้นมาใน 4 The Reactive Extensions ไลบรารีจาก Microsoft คือ implementations ของอินเทอร์เฟซเหล่านี้ได้อย่างรวดเร็วยกขึ้น traction กับเซิร์ฟเวอร์ไคลเอ็นต์และนักพัฒนาเว็บเหมือน Rx เป็นเครื่องมือการพัฒนาที่มีประสิทธิผล Rx ช่วยให้นักพัฒนาสามารถแก้ปัญหาในรูปแบบที่สง่างามคุ้นเคยและเปิดเผยโดยส่วนใหญ่จะมีโค้ดน้อยกว่าที่เป็นไปได้โดยไม่ต้องใช้ Rx โดยการใช้ประโยชน์จาก LINQ, Rx ได้รับประโยชน์มาตรฐานของการใช้ LINQ 1. Integrated LINQ ถูกรวมเข้าไปในภาษา C Unitive Using LINQ ช่วยให้คุณสามารถใช้ประโยชน์จากทักษะที่มีอยู่ของคุณสำหรับการสืบค้นข้อมูลในส่วนที่เหลือ LINQ to SQL, LINQ to XML หรือ LINQ ไปยังวัตถุที่ต้องการสืบค้นข้อมูลที่เคลื่อนไหวคุณสามารถคิด Rx เป็น LINQ กับเหตุการณ์ LINQ ช่วยให้คุณสามารถเปลี่ยนจากกระบวนทัศน์อื่น ๆ ไปสู่กระบวนทัศน์ทั่วไป ตัวอย่างเช่นคุณสามารถเปลี่ยนเหตุการณ์มาตรฐานการเรียกเมธอดแบบอะซิงโครนัสงานหรืออาจเป็นตัวกลางมิดเดิลแวร์ของบุคคลที่ 3 เป็นหนึ่งเดียว mmon Rx โดยใช้ประโยชน์จากภาษาที่มีอยู่ของเราในการเลือกใช้โอเปอเรเตอร์ที่คุ้นเคยเช่น Select Where GroupBy ฯลฯ นักพัฒนาซอฟต์แวร์สามารถหาเหตุผลเข้าข้างตนเองและสื่อสารการออกแบบหรือโค้ดในรูปแบบทั่วไป Extensible คุณสามารถขยาย Rx ด้วยวิธีการต่อขยายตัวดำเนินการแบบสอบถามที่กำหนดเองของคุณ Declarative LINQ ช่วยให้โค้ดของคุณ เพื่ออ่านเป็นคำประกาศของสิ่งที่รหัสของคุณไม่และใบวิธีการดำเนินงานของผู้ประกอบการคุณสมบัติ Composable LINQ เช่นวิธีการขยายไวยากรณ์แลมบ์ดาและไวยากรณ์ความเข้าใจแบบสอบถามให้คล่องแคล่ว API สำหรับนักพัฒนาที่จะบริโภคแบบสอบถามสามารถสร้างด้วยจำนวนมาก ผู้ให้บริการคำค้นหาสามารถรวมกันเพื่อสร้างคอมโพสิตได้มากขึ้นด้วย Query แบบเปลี่ยนได้สามารถแปลงข้อมูลจากประเภทหนึ่งไปเป็นอีกแบบหนึ่งแบบสอบถามอาจแปลค่าเดี่ยวเป็นค่าอื่นรวมจากลำดับค่าเป็นค่าเฉลี่ยเดียวหรือขยายข้อมูลเดี่ยว ค่าลงในลำดับของค่าเมื่อ Rx เหมาะสม Rx เสนอกระบวนทัศน์ตามธรรมชาติสำหรับ การจัดการกับลำดับของเหตุการณ์ลำดับสามารถประกอบด้วยศูนย์หรือมากกว่าเหตุการณ์ Rx พิสูจน์ให้มีค่ามากที่สุดเมื่อเขียนลำดับของเหตุการณ์ควรใช้เหตุการณ์ Rx. Managing เช่นนี้คือสิ่งที่ Rx ถูกสร้างขึ้นสำหรับกิจกรรม UI เช่นการเลื่อนเมาส์ click. domain ปุ่ม เหตุการณ์เช่นคุณสมบัติการเปลี่ยนแปลงการเก็บรวบรวมการอัปเดตการสั่งซื้อการลงทะเบียนการยอมรับ ฯลฯ เหตุการณ์โครงสร้างพื้นฐานเช่นจากผู้ตรวจสอบไฟล์ระบบและเหตุการณ์ WMI เหตุการณ์การรวมระบบเช่นการออกอากาศจากบัสข้อความหรือเหตุการณ์จาก WebSockets API หรือตัวกลางที่มีความหน่วงต่ำอื่น ๆ เช่นนิพพาน การรวมเข้ากับโปรแกรม CEP เช่น StreamInsight หรือ StreamBase. Interestingly ผลิตภัณฑ์ของ Microsoft CEP StreamInsight ซึ่งเป็นส่วนหนึ่งของตระกูล SQL Server ใช้ LINQ ในการสร้างแบบสอบถามเกี่ยวกับการสตรีมข้อมูลของข้อมูลนอกจากนี้ Rx ยังเหมาะสำหรับการแนะนำและการจัดการภาวะพร้อมกันสำหรับ วัตถุประสงค์ของการ offloading นั่นคือการปฏิบัติชุดกำหนดของการทำงานพร้อมกันเพื่อเพิ่มหัวข้อปัจจุบันการใช้งานที่เป็นที่นิยมมากนี้คือการรักษา responsi UI คุณควรพิจารณาใช้ Rx ถ้าคุณมี T IEnumerable ที่มีอยู่ซึ่งกำลังพยายามจำลองข้อมูลในขณะเคลื่อนที่ขณะที่ IEnumerable T สามารถจำลองข้อมูลในการเคลื่อนที่โดยใช้การประเมินผลที่ขี้เกียจเช่นผลตอบแทนที่ได้รับอาจได้รับรางวัล t scale Iterating เหนือ IEnumerable T กินบล็อกเธรดคุณควรจะชอบธรรมชาติที่ไม่ปิดกั้นของ Rx ผ่านทาง IObservable T หรือพิจารณาคุณสมบัติ async ใน 4 5.Could ใช้ Rx. Rx สามารถใช้สำหรับการโทรไม่ตรงกันเหล่านี้มีประสิทธิภาพลำดับของหนึ่ง eventResult of งานหรือ Task T. Result ของวิธีการเรียก APM เช่น FileStream BeginRead EndRead. You อาจพบการใช้ TPL, Dataflow หรือคำหลัก async 4 5 พิสูจน์ให้เป็นวิธีที่เป็นธรรมชาติมากขึ้นในการเขียนวิธีการแบบอะซิงโครนัสในขณะที่ Rx แน่นอนสามารถช่วยให้กับสถานการณ์เหล่านี้, ถ้ามีกรอบที่เหมาะสมอื่น ๆ ที่คุณควรพิจารณาก่อนสามารถใช้ Rx แต่ไม่เหมาะสำหรับแนะนำและจัดการภาวะพร้อมกันเพื่อให้เป็นไปตามวัตถุประสงค์ของการปรับขนาดหรือการทำงานแบบขนาน comp utations กรอบที่ทุ่มเทอื่น ๆ เช่น TPL Task Parallel Library หรือ C AMP มีความเหมาะสมกับการทำงานแบบขนานมากขึ้นเรื่อย ๆ โดยเฉพาะ IObservable T ไม่ใช่การทดแทน IEnumerable TI ไม่แนะนำให้ลองใช้สิ่งที่ดึงตามธรรมชาติและบังคับให้ จะผลักดัน based. Translating ที่มีอยู่ค่า IEnumerable T เพื่อ IObservable T เพียงเพื่อให้ฐานรหัสสามารถเพิ่มเติม Rx. Message Queues Queues เช่นใน MSMQ หรือการใช้ JMS โดยทั่วไปมีการทำธุรกรรมและตามคำนิยามตามลำดับฉันรู้สึก IEnumerable T เป็นแบบธรรมชาติสำหรับ here. By เลือกเครื่องมือที่ดีที่สุดสำหรับงานรหัสของคุณควรจะง่ายต่อการรักษาให้ประสิทธิภาพที่ดีขึ้นและคุณอาจจะได้รับการสนับสนุนที่ดีกว่า Rx ใน action. Adopting และการเรียนรู้ Rx สามารถเป็นวิธีซ้ำที่คุณสามารถใช้มันช้าไป โครงสร้างพื้นฐานและโดเมนในระยะเวลาสั้น ๆ คุณควรจะสามารถมีทักษะในการผลิตโค้ดหรือลดโค้ดที่มีอยู่ให้เป็นคำที่ประกอบด้วยคำสั่งง่ายๆ erators ตัวอย่างเช่น Simple ViewModel นี้เป็นสิ่งที่ฉันต้องการในการรวมการค้นหาที่จะดำเนินการเป็นชนิด users. public class MemberSearchViewModel INotifyPropertyChanged. While ข้อมูลโค้ดนี้มีขนาดค่อนข้างเล็กสนับสนุนข้อกำหนดต่อไปนี้ไว้รองรับ UI. Supports timeouts. Knows เมื่อการค้นหาเสร็จสมบูรณ์อนุญาตให้ผลลัพธ์กลับมาทีละหนึ่งข้อผิดพลาด time. Handles สามารถทดสอบได้แม้จะมีความกังวลเกี่ยวกับ concurrency ถ้าผู้ใช้เปลี่ยนแปลงการค้นหาให้ยกเลิกการค้นหาปัจจุบันและดำเนินการค้นหาใหม่ด้วยข้อความใหม่ ในการผลิตตัวอย่างนี้เกือบจะเป็นกรณีของการเขียนผู้ประกอบการที่ตรงกับความต้องการในแบบสอบถามเดียวแบบสอบถามมีขนาดเล็ก maintainable declarative และไกลน้อยกว่ารหัสของคุณเองมีประโยชน์เพิ่มเติมของ reusing ดีทดสอบ API รหัสน้อย คุณต้องเขียนรหัสน้อยที่คุณต้องทดสอบการแก้ปัญหาและรักษาสร้างคำอื่นเช่นต่อไปนี้เป็น simple. calculating ค่าเฉลี่ยเคลื่อนที่ของชุดของค่าเช่นบริการ lev ข้อตกลง el สำหรับ latencies เฉลี่ยหรือ downtime ข้อมูลเหตุการณ์จากหลายแหล่งเช่นผลการค้นหาจาก Bing, Google และ Yahoo หรือข้อมูลเซ็นเซอร์จาก Accelerometer, Gyro, Magnetometer หรือ temperatures. grouping ข้อมูลเช่น tweets ตามหัวข้อหรือผู้ใช้หรือราคาหุ้นโดยเดลต้าหรือสภาพคล่อง การกรองข้อมูลเช่นเซิร์ฟเวอร์เกมออนไลน์ภายในภูมิภาคสำหรับเกมที่เฉพาะเจาะจงหรือมีจำนวนผู้เข้าร่วมต่ำสุดอยู่ที่นี่การจับกลุ่มด้วย Rx เป็นวิธีที่มีประสิทธิภาพเพื่อตอบสนองความคาดหวังของผู้ใช้ในโลกแห่งการผลักดันด้วยการทำความเข้าใจและแต่งส่วนประกอบที่เป็นส่วนประกอบของ Rx คุณจะสามารถทำให้การทำงานสั้น ๆ ของความซับซ้อนของการประมวลผลเหตุการณ์ขาเข้า Rx ถูกตั้งค่าให้กลายเป็นส่วนหนึ่งในชีวิตประจำวันของประสบการณ์การเขียนโปรแกรมของคุณแนะนำที่เป็นประโยชน์ Read. Lee แคมป์เบลแนะนำ Rx จุดรุ่น 2012 ผลของการบังเอิญ ของส่วนของหนังสือเล่มนี้ตอนนี้ได้กล่าวถึงแนวคิดที่เป็นอิสระอย่างเป็นอิสระประเภทคีย์การจัดการอายุการใช้งาน Anamorphism, Catamorphism, Binding, Flow control, Scheduling และ Testing I n บทก่อนหน้านี้เราได้พิจารณารวมหลายลำดับกับผู้ประกอบการเช่น SelectMany Merge Zip Concat ฯลฯ ผู้ประกอบการเหล่านี้เป็นบิตง่ายกว่าผู้ประกอบการในบทนี้บทสุดท้ายนี้มีลักษณะที่จะรวมหลายหัวข้อเหล่านี้เพื่อให้เราอาจจะสามารถจัดการกับลำดับพร้อมกัน, หรือ Sequences of Coincidence. We สามารถ conceuptualise เหตุการณ์ที่มีระยะเวลาที่จะเป็น Windows ตัวอย่างมี Server ขึ้นคนอยู่ในห้องกดปุ่มและยังไม่ออกสิ่งเหล่านี้อาจเป็นอีก worded เป็นหน้าต่างของเวลานี้, เซิร์ฟเวอร์ขึ้นเมื่อหน้าต่างทับซ้อนกันพวกเขากล่าวกันว่าตรงเวลา. Buffer revisted. Buffer ไม่ใช่ผู้ดำเนินการใหม่ให้กับเรา แต่ขณะนี้คุณสามารถจัดกลุ่มแนวคิดด้วยตัวดำเนินการหน้าต่างโอเปอเรเตอร์เหล่านี้ทั้งหมดทำอะไรกับลำดับและหน้าต่าง ของเวลาผู้ประกอบการแต่ละคนจะเปิดหน้าต่างเมื่อลำดับแหล่งที่มาผลิตค่าทางหน้าต่างถูกปิดและค่าที่สัมผัสคือความแตกต่างหลักระหว่างแต่ละผู้ประกอบการ Let เราเพิ่งสรุปการทำงานภายในของ Buffer เพื่อนเก่าและดูว่าแผนที่นี้กับแนวคิดของหน้าต่างของ Time. Buffer จะสร้างหน้าต่างเมื่อมีการสร้างค่าแรกจากนั้นจะใส่ค่านั้นลงในแคชภายในหน้าต่างจะยังคงอยู่ เปิดจนกว่าจะมีการนับค่าถึงค่าเหล่านี้แต่ละค่าจะถูกแคชตอนนี้นับว่าถึงแล้วหน้าต่างจะปิดและแคชจะเป็น OnNext ed เป็น IList T เมื่อมีการสร้างมูลค่าต่อไปจากแหล่งข้อมูล แคชจะถูกล้างและเราเริ่มต้นอีกครั้งซึ่งหมายความว่าบัฟเฟอร์จะใช้ IObservable T และส่งคืน Iistemsable IList T. Example บัฟเฟอร์ที่มีจำนวน 3. ในแผนผังหินอ่อนนี้ฉันได้แสดงรายการค่าที่ถูกส่งกลับมาที่จุดในเวลาเป็น คอลัมน์ของข้อมูลคือค่า 0, 1 2 ทั้งหมดจะถูกส่งกลับมาในบัฟเฟอร์ตัวแรกโดยสรุปแล้วมันไม่ได้เป็นการกระโดดมากพอที่จะเข้าใจบัฟเฟอร์กับเวลาแทนการนับจำนวนที่เราส่งผ่าน TimeSpan การปิดหน้าต่างและ กันชน s แคชอยู่ในขณะนี้ dictated โดยเวลาแทนที่จะนับค่าที่ผลิตนี้เป็นที่เคยดังนั้นซับซ้อนมากขึ้นขณะนี้เราได้นำเสนอการเรียงลำดับของการจัดตารางการผลิต IList T ในจุดที่ถูกต้องในเวลาที่เราต้องกำหนดการกำหนดให้มีประสิทธิภาพการกำหนดเวลา นอกจากนี้ยังทำให้การทดสอบสิ่งนี้ง่ายขึ้นมากตัวอย่างเช่นบัฟเฟอร์ที่มีเวลาของ 5 หน่วยตัวอย่างเช่น Revised. IObservable TSource ตัวอย่างนี้ IObservable TSOR, IObservable TTick ผู้ประกอบการหน้าต่างมีความคล้ายคลึงกับตัวดำเนินการ Buffer พวกเขาเพียงจริงๆแตกต่างกันตามประเภทการส่งคืนของพวกเขา ที่บัฟเฟอร์จะใช้ IObservable T และส่งคืนค่า IObservable IList T ผู้ดำเนินงาน Window จะคืนค่า IObservable IObservable T นอกจากนี้ยังควรสังเกตด้วยว่าตัวดำเนินการ Buffer จะไม่ยอมให้บัฟเฟอร์ของตนจนกว่าหน้าต่างจะปิดไปที่นี่เราสามารถดู overloads แบบง่ายๆได้ที่ Window There เป็น symetry ที่น่าแปลกใจกับ Window และ Buffer overloads. public สาธารณะ IObservable IObservable TSource Window TSource นี้แหล่ง TSO IObservable, int int count. public คง IObservable IObservable TSource Window TSource นี้แหล่ง TSO IObservable นับ int int skip. public คง IObservable IObservable TSource Window TSource นี้แหล่ง TSO IObservable, TimeSpan timeSpan. public คง IObservable IObservable TSource Window TSource นี้แหล่ง IObservable TSF, timeSpan timeSpan นับ int สาธารณะคง IObservable IObservable TSource Window TSource นี้แหล่ง TSO IObservable, TimeSpan timeSpan, TimeSpan timeShift. public คง IObservable IObservable TSource Window TSource นี้แหล่ง TSO IObservable, TimeSpan timeSpan, IScheduler scheduler. public IObservable IObservable TSource Window TSource นี้แหล่ง IObservable TSF, TimeSpan timeSpan TimeSpan timeShift, IScheduler scheduler. public static IObservable IObservable TSource Window TSource แหล่งข้อมูล IObservable TSource, TimeSpan timeSpan, นับ int, IScheduler scheduler. Example ของ Window ที่มีจำนวน 3 ตัวอย่างหน้าต่างที่มีเวลา 5 หน่วยความแตกต่างที่สำคัญ e เราเห็นนี่คือ Window operator สามารถแจ้งให้คุณทราบถึงค่าจากแหล่งข้อมูลได้ทันทีที่มีการผลิตตัวเก็บบัฟเฟอร์ต้องรอจนกว่าหน้าต่างจะปิดก่อนที่ค่าจะได้รับแจ้งเป็นรายการทั้งหมดการปรับขนาดการทำงานของ Window ฉันคิดว่า เป็นมูลค่า noting อย่างน้อยจากจุดทางวิชาการที่ผู้ประกอบการ Window ผลิต IObservable IObservable T เราได้สำรวจแนวคิดของ observables ที่ซ้อนกันในบทก่อนหน้านี้รวมรวมกันและสลับแต่ละคนมีมากเกินไปที่จะ IObservable IObservable T และส่งกลับค่า IObservable T ในฐานะที่โอเปอเรเตอร์ Window มั่นใจว่าลำดับลูกของ Windows ไม่ทับซ้อนกันเราสามารถใช้อย่างใดอย่างหนึ่งของ Concat Switch หรือ Merge operators เพื่อเปลี่ยนลำดับของ windowed กลับไปเป็นลำดับแรก เป็นเช่นเดียวกับการเปลี่ยน swindowWindow Observable TimeSpan. WindowWithTime TimeSpan. Customizing Windows overloads ดังกล่าวให้วิธีง่ายๆในการทำลายลำดับในหน้าต่างที่ซ้อนกันขนาดเล็กโดยใช้การนับและหรือช่วงเวลาตอนนี้เราจะดูที่ overloads ที่ให้คุณด้วย ความยืดหยุ่นมากขึ้นเกี่ยวกับวิธีการจัดการหน้าต่างของคุณ จัดองค์ประกอบแต่ละส่วนของลำดับที่สังเกตได้ลงในหน้าต่างที่ไม่ทับซ้อนกัน windowClosingSelector ฟังก์ชันที่เรียกใช้เพื่อกำหนดขอบเขตของหน้าต่างที่สร้างหน้าต่างใหม่จะเริ่มทำงานเมื่อหน้าก่อนหน้านี้ถูกปิดหน้าต่าง Public static IObservable IObservable TSource Window TSource, TWindow การปิดแหล่งข้อมูล TSO IObservable นี้ Func IObservable TWindowClosing windowClosingSelector. แรกของ overloads ซับซ้อนเหล่านี้ช่วยให้ เราจะควบคุมเมื่อหน้าต่างปิดฟังก์ชัน windowClosingSelector เรียกว่าทุกครั้งที่มีการสร้างหน้าต่าง Windows จะสร้างขึ้นในการบอกรับเป็นสมาชิกและทันทีที่หน้าต่างปิดหน้าต่างปิดเมื่อลำดับจากหน้าต่างClosingSelectorสร้างค่าค่าจะถูกละเลยจึงไม่สำคัญว่า ประเภทของค่าลำดับคือในความเป็นจริงคุณสามารถแม้เพียงกรอกลำดับจาก windowClosingSelector เพื่อปิดหน้าต่างในตัวอย่างนี้เราสร้างหน้าต่างที่มีตัวเลือกการปิดหน้าต่างเราจะส่งคืนหัวเรื่องเดียวกันจากตัวเลือกแต่ละครั้งและแจ้งจากหัวข้อ เมื่อผู้ใช้กดเข้าจาก console. var windo wIdx 0.var source Observable TimeSpan. var หัวข้อใหม่ที่ใกล้เคียง ใกล้เกินไปซับซ้อนมากเกินไปของหน้าต่างช่วยให้เราสามารถสร้างหน้าต่างทับซ้อนกันที่อาจเกิดขึ้น โครงการแต่ละองค์ประกอบของลำดับที่สามารถสังเกตได้เป็นศูนย์หรือมากกว่าหน้าต่าง ลำดับที่สังเกตได้ซึ่งองค์ประกอบแสดงถึงการสร้างหน้าต่างใหม่ windowClosingSelector ฟังก์ชั่นที่เรียกใช้เพื่อกำหนดการปิดหน้าต่างที่ผลิตในแต่ละ window. console แบบคงที่ IObservable IObservable TSource Window, TWindowOpening, TWindow การปิดใช้งานแหล่งข้อมูล TSO IObservable นี้, เปิดหน้าต่าง IObservedOpenings, Func TWindowOpening, IObservable TWindowClosing windowClosingSelector การโอเวอร์โหลดใช้เวลา 3 อาร์กิวเมนต์ลำดับแหล่งที่มา ลำดับที่ระบุเมื่อต้องเปิดหน้าต่างใหม่ฟังก์ชั่นที่ใช้ค่าเปิดหน้าต่างและส่งกลับลำดับการปิดหน้าต่างการโอเวอร์โหลดนี้มีความยืดหยุ่นมากในการเปิดและปิดหน้าต่าง Windows สามารถเป็นอิสระจากกันได้เป็นอย่างมาก สามารถทับซ้อนทับกันแตกต่างกันไปในขนาดและแม้แต่ข้ามค่าจากซอร์สโค้ดเพื่อความสะดวกในการใช้งานเกินพิกัดที่ซับซ้อนมากขึ้นให้ลองลองใช้หน้าต่างรุ่นที่เรียบง่ายขึ้นซึ่งจะใช้เวลาในการคำนวณ เพื่อเปิดหน้าต่างในการสมัครสมาชิกแบบครั้งแรกและทุกครั้งที่แหล่งข้อมูลได้สร้างจำนวนที่ระบุไว้แล้ว T เขาหน้าต่างต้องปิดทุกครั้งที่แหล่งผลิตนับที่กำหนดเพื่อให้บรรลุนี้เราจะต้องลำดับแหล่งเราจะแบ่งปันโดยใช้วิธีการเผยแพร่แล้วจัดหามุมมองของแหล่งที่มาเป็นแต่ละอาร์กิวเมนต์สาธารณะ IObservable IObservable T MyWindow T นี้แหล่งที่มา IObservable, int count. var windowEdge shared. It อาจเป็นที่น่าสนใจที่จะต้องพิจารณาวิธีที่คุณอาจใช้วิธีอื่น ๆ ขยับเช่นตัวอย่างหรือเค้นกับ Window. The ผู้ประกอบการเข้าร่วมช่วยให้คุณสามารถตรรกะเข้าร่วมสองลำดับที่ผู้ประกอบการซิป จะเข้าร่วมสอง seqences ร่วมกันโดยดัชนีตัวดำเนินการเข้าร่วมช่วยให้คุณสามารถเข้าร่วม sequences โดย intersecting windows เช่นเดียวกับหน้าต่างสุดท้าย overload เราเพียงแค่มองที่คุณสามารถระบุเมื่อหน้าต่างปิดจากฟังก์ชันที่ใช้ค่าเปิดและส่งกลับลำดับการสังเกตเพื่อบ่งชี้ เมื่อหน้าต่างควรจะปิดตัวดำเนินการเข้าร่วมมีสองฟังก์ชันดังกล่าวหนึ่งสำหรับลำดับแหล่งแรกและหนึ่งสำหรับลำดับแหล่งที่มาที่สองเช่นเดียวกับ Zip operato r เราจำเป็นต้องให้ฟังก์ชัน selector เพื่อสร้างไอเท็มผลลัพธ์จากคู่ของ values. public static IObservable TResult เข้าร่วม TLeft, TRight, TLeftDuration, TRightDuration, TResult. this IObservable TLeft left. IObservable TRight right. Func TLeft, IObservable TLeftDuration leftDurationSelector. Func TRight, IObservable TRightDuration rightDurationSelector. Func TLeft, TRight, TResult resultSelector ตอนนี้นี่เป็นลายเซ็นขนที่มีขนค่อนข้างมากและพยายามเข้าใจในครั้งเดียวดังนั้นลองเอาพารามิเตอร์นี้ไปทีละหนึ่งครั้ง TLUT ซ้ายนำมาใช้เป็นลำดับแหล่งข้อมูลที่กำหนด เมื่อหน้าต่างเริ่มต้นเช่นเดียวกับตัวดำเนินการบัฟเฟอร์และหน้าต่างยกเว้นว่าค่าที่ตีพิมพ์จากแหล่งข้อมูลนี้ทั้งหมดจะเปิดหน้าต่างใหม่ในบัฟเฟอร์และหน้าต่างบางค่าเพียงแค่ลดลงในหน้าต่างที่มีอยู่ฉันชอบที่จะคิดว่า IObservable TRight ถูกต้องเป็นค่าหน้าต่าง ลำดับขณะที่ลำดับซ้ายควบคุมการเปิดหน้าต่างลำดับด้านขวาจะพยายามจับคู่กับค่าจากลำดับซ้ายให้เราลองจินตนาการว่า ลำดับด้านซ้ายของเราจะสร้างมูลค่าซึ่งจะสร้างหน้าต่างใหม่หากลำดับด้านขวาสร้างค่าในขณะที่หน้าต่างเปิดอยู่ฟังก์ชัน resultSelector จะเรียกว่ามีค่าสองค่านี่เป็นส่วนสำคัญของการเข้าร่วมการจับคู่ค่าสองค่าจากลำดับที่เกิดขึ้น ในหน้าต่างเดียวกันหน้าต่างนี้จะนำเราไปสู่คำถามถัดไปเมื่อใดที่หน้าต่างปิดคำตอบสำหรับคำถามนี้เป็นทั้งพลังและความซับซ้อนของโอเปอเรเตอร์ Join เมื่อซ้ายสร้างค่าหน้าต่างจะเปิดขึ้นค่านี้จะถูกส่งผ่านไปยัง ฟังก์ชัน leftDurationSelector ผลของฟังก์ชันนี้คือ IObservable TLeftDuration เมื่อลำดับที่สร้างค่าหรือเสร็จสมบูรณ์แล้วหน้าต่างสำหรับค่าที่ถูกปิดหมายเหตุว่าไม่เกี่ยวข้องกับสิ่งที่ประเภทของ TLeftDuration นี้เริ่มต้นฉันด้วยความรู้สึกว่า IObservable TLeftDuration เป็น ทุกบิตกว่าฆ่าที่คุณมีประสิทธิภาพเพียงแค่ต้องจัดเรียงของเหตุการณ์บางอย่างที่จะพูดปิด แต่โดยให้คุณสามารถใช้ IObservable T คุณสามารถทำสิ่งที่ฉลาดบางอย่างที่เราทำ ป่วยดูต่อมาให้เราลองนึกภาพสถานการณ์ที่เรามีลำดับซ้ายสร้างค่าสองครั้งให้เร็วที่สุดเท่าลำดับด้านขวาลองนึกภาพว่าเรายังไม่ปิดหน้าต่างเราสามารถทำได้โดยการคืนหน่วยเสมอจากฟังก์ชัน leftDurationSelector ซึ่งจะส่งผลให้ คู่ต่อไปนี้ถูกผลิตเมื่อคุณเห็นค่าด้านซ้ายถูกแคชและเล่นใหม่ทุกครั้งที่ด้านขวาสร้างมูลค่าตอนนี้ดูเหมือนว่าค่อนข้างชัดเจนว่าถ้าฉันปิดหน้าต่างทันทีโดยการส่งคืนหน่วยหรืออาจจะไม่เปิดหน้าต่างดังนั้นไม่มี คู่ที่เคยจะได้รับการผลิตอย่างไรก็ตามสิ่งที่ฉันสามารถทำเพื่อให้แน่ใจว่าหน้าต่างเหล่านี้ไม่ทับซ้อนกันเพื่อที่ว่าเมื่อค่าที่สองถูกผลิตฉันจะไม่เห็นค่าแรกดีถ้าเรากลับลำดับซ้ายจาก leftDurationSelector ที่สามารถทำมัน แต่รอเมื่อเรากลับซ้ายจาก LeftDurationSelector ก็จะพยายามสร้างการสมัครสมาชิกใหม่และที่อาจแนะนำผลข้างเคียงคำตอบอย่างรวดเร็วเพื่อที่จะเผยแพร่และ refCount ลำดับซ้ายถ้าเราทำผลที่มีลักษณะเช่นนี้ตัวอย่างสุดท้ายคล้ายกับ CombineLatest ยกเว้นว่าเป็นเพียงการผลิตคู่เมื่อเปลี่ยนลำดับขวาเราสามารถใช้เข้าร่วมในการผลิตของเราเองรุ่นของ CombineLatest ถ้าค่า จากลำดับซ้ายหมดอายุเมื่อค่าถัดไปจากซ้ายได้รับการแจ้งแล้วฉันจะดีในทางของฉัน แต่ฉันต้องการสิ่งเดียวกันที่เกิดขึ้นสำหรับสิทธิโชคดีเข้าร่วมดำเนินการยังให้เรา rightDurationSelector ที่ทำงานเช่นเดียวกับ leftDurationSelector นี้ง่าย ที่จะใช้สิ่งที่ฉันต้องทำคือการส่งกลับการอ้างอิงไปยังลำดับซ้ายเดียวกันเมื่อมีการสร้างค่าด้านซ้ายแล้วเหมือนกันสำหรับโค้ดด้านขวาโค้ดจะมีลักษณะเป็น this. public static IObservable TResult MyCombineLatest TLeft, TRight, TResult. IObservable TLeft left ขวาขวา TRADE. While รหัสข้างต้นไม่ได้เป็นคุณภาพการผลิตก็จะต้องมีประตูบางอย่างในสถานที่เพื่อลดเงื่อนไขการแข่งขันก็แสดงให้เราเห็นพลังที่เราสามารถ get with Join เราสามารถใช้งานได้จริงเพื่อสร้างโอเปอเรเตอร์อื่น ๆ เมื่อผู้ดำเนินการ Join จับคู่ค่าที่สอดคล้องกันภายในหน้าต่างจะทำให้เกิดค่าที่เหลือและค่าที่เหมาะสมไปยัง resultSelector ตัวดำเนินการ GroupJoin จะใช้ขั้นตอนต่อไปนี้ไปอีกขั้นหนึ่ง ผ่านค่าด้านซ้ายทันทีเพื่อ resultSelector กับลำดับของค่าด้านขวาที่เกิดขึ้นภายในหน้าต่างลายเซ็นของมันจะคล้ายกับการเข้าร่วม แต่ทราบความแตกต่างใน resultSelector Func. public คง IObservable TResult GroupJoin TLeft, TRight, TLeftDuration, TRightDuration, TResult. this IObservable TLeft left. IObservable TRight right. Func TLeft, IObservable TLeftDuration leftDurationSelector. Func TRight, IObservable TRightDuration rightDurationSelector. Func TLeft, IObservable TRight, TResult resultSelector ถ้าเรากลับไปที่ตัวอย่างการเข้าร่วมครั้งแรกของเราที่เราได้ผลิตทิ้งไว้ ค่าสองครั้งเร็วเท่าที่ด้านขวาซ้ายไม่มีวันหมดอายุขวาที่หมดอายุทันทีนี้เป็นสิ่งที่ผล อาจมีลักษณะเหมือนตอนนี้เราสามารถเปลี่ยนได้รอบ ๆ และมีมันที่ด้านซ้ายหมดอายุทันทีและด้านขวาไม่เคยหมดอายุผลอาจมีลักษณะเช่นนี้เริ่มต้นที่จะทำให้สิ่งที่น่าสนใจผู้อ่านชาร์ปอาจสังเกตว่าด้วย GroupJoin คุณสามารถสร้างใหม่ได้อย่างมีประสิทธิภาพ เข้าร่วมของคุณเองโดยทำสิ่งที่ชอบ this. public IObservable TResult MyJoin TLeft, TRight, TLeftDuration, TRightDuration, TResult. IObservable TLeft left. IObservable TRight right. Func TLeft, IObservable TLeftDuration leftDurationSelector. Func TRight, IObservable TRightDuration rightDurationSelector. Func TLeft, TRight, ผลลัพธ์ TRESULT